| Modifier and Type | Method and Description |
|---|---|
Map<String,ISqlStreamsDataSource> |
StormSqlContext.getDataSources() |
| Modifier and Type | Method and Description |
|---|---|
ISqlStreamsDataSource |
HdfsDataSourcesProvider.constructStreams(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
| Modifier and Type | Method and Description |
|---|---|
ISqlStreamsDataSource |
KafkaDataSourcesProvider.constructStreams(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
| Modifier and Type | Method and Description |
|---|---|
ISqlStreamsDataSource |
MongoDataSourcesProvider.constructStreams(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,ISqlStreamsDataSource> |
StreamsPlanCreator.getSources() |
| Modifier and Type | Method and Description |
|---|---|
AbstractStreamsProcessor |
QueryPlanner.compile(Map<String,ISqlStreamsDataSource> sources,
String query) |
| Constructor and Description |
|---|
StreamsPlanCreator(Map<String,ISqlStreamsDataSource> sources,
org.apache.calcite.rex.RexBuilder rexBuilder) |
| Modifier and Type | Method and Description |
|---|---|
ISqlStreamsDataSource |
RedisDataSourcesProvider.constructStreams(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties props,
List<FieldInfo> fields) |
| Modifier and Type | Method and Description |
|---|---|
ISqlStreamsDataSource |
DataSourcesProvider.constructStreams(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields)
Construct a new data source for streams mode.
|
static ISqlStreamsDataSource |
DataSourcesRegistry.constructStreamsDataSource(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields)
Construct a streams data source.
|
| Modifier and Type | Method and Description |
|---|---|
ISqlStreamsDataSource |
SocketDataSourcesProvider.constructStreams(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.