Modifier and Type | Method and Description |
---|---|
ISqlTridentDataSource |
HdfsDataSourcesProvider.constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
Modifier and Type | Method and Description |
---|---|
ISqlTridentDataSource |
KafkaDataSourcesProvider.constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
Modifier and Type | Method and Description |
---|---|
ISqlTridentDataSource |
MongoDataSourcesProvider.constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
Modifier and Type | Method and Description |
---|---|
Map<String,ISqlTridentDataSource> |
TridentPlanCreator.getSources() |
Modifier and Type | Method and Description |
---|---|
AbstractTridentProcessor |
QueryPlanner.compile(Map<String,ISqlTridentDataSource> sources,
String query) |
Constructor and Description |
---|
TridentPlanCreator(Map<String,ISqlTridentDataSource> sources,
org.apache.calcite.rex.RexBuilder rexBuilder) |
Modifier and Type | Method and Description |
---|---|
ISqlTridentDataSource |
RedisDataSourcesProvider.constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties props,
List<FieldInfo> fields) |
Modifier and Type | Method and Description |
---|---|
ISqlTridentDataSource |
DataSourcesProvider.constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
static ISqlTridentDataSource |
DataSourcesRegistry.constructTridentDataSource(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
Modifier and Type | Method and Description |
---|---|
ISqlTridentDataSource |
SocketDataSourcesProvider.constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.