Package 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	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	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()