public class FlinkParsedDataSource extends ParsedDataSource
org.apache.mrql.DataSource.DataSourceDirectory, org.apache.mrql.DataSource.ParserDirectory
args, parser
dataSourceDirectory, inputFormat, parserDirectory, path, separator, source_num, to_be_merged, tuple_container
Constructor and Description |
---|
FlinkParsedDataSource(String path,
Class<? extends org.apache.mrql.Parser> parser,
Trees args) |
toString
, get, getCached, loadParsers, read, reduce, size, take
FlinkParsedDataSource(String path, Class<? extends org.apache.mrql.Parser> parser, Trees args)
Copyright © 2013-2015 The Apache Software Foundation. All Rights Reserved.