dharadhruve

class Toto
{
    public void Main()
    {
        final DataFrame source = GetDataFrame();
        final String querySelectSQL = flattenSchema(source.schema(), null);

        source.registerTempTable("source"); 
      
        final DataFrame flattenData = sqlContext.sql("SELECT " + querySelectSQL + " FROM source")

gxercavins

import argparse, json, logging, time

import apache_beam as beam
import apache_beam.transforms.window as window
from apache_beam.io import WriteToText
from apache_beam.options.pipeline_options import PipelineOptions
from apache_beam.options.pipeline_options import SetupOptions


class AnalyzeSession(beam.DoFn):