org.apache.pinot.tools.streams

Class AirlineDataStream

java.lang.Object

org.apache.pinot.tools.streams.AirlineDataStream

public class AirlineDataStream
extends Object

This is used in Hybrid Quickstart.

Constructor Summary

Constructors

Constructor and Description
AirlineDataStream(org.apache.pinot.spi.data.Schema pinotSchema, org.apache.pinot.spi.config.table.TableConfig tableConfig, File avroFile)

Method Summary

Modifier and Type	Method and Description
void	run()
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AirlineDataStream

public AirlineDataStream(org.apache.pinot.spi.data.Schema pinotSchema,
                         org.apache.pinot.spi.config.table.TableConfig tableConfig,
                         File avroFile)
                  throws Exception

Throws:

Exception

Method Detail

shutdown

public void shutdown()

run

public void run()