public final class FlinkXMLParser extends XMLParser implements FlinkParser
Modifier and Type | Field and Description |
---|---|
(package private) FlinkXMLSplitter |
splitter |
Constructor and Description |
---|
FlinkXMLParser() |
Modifier and Type | Method and Description |
---|---|
void |
initialize(Trees arg0) |
void |
open(org.apache.flink.core.fs.FSDataInputStream fsin,
long start,
long end) |
void |
open(org.apache.hadoop.fs.FSDataInputStream arg0,
long arg1,
long arg2) |
void |
open(String file) |
void |
open(String arg0,
int arg1) |
Bag |
parse(String arg0) |
String |
slice() |
Tree |
type() |
FlinkXMLSplitter splitter
public void open(org.apache.flink.core.fs.FSDataInputStream fsin, long start, long end)
open
in interface FlinkParser
public void initialize(Trees arg0)
public Tree type()
public void open(org.apache.hadoop.fs.FSDataInputStream arg0, long arg1, long arg2)
public void open(String arg0, int arg1)
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.