public class PTFPartition extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
PTFPartition.PTFPartitionIterator<T> |
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
Modifier | Constructor and Description |
---|---|
protected |
PTFPartition(org.apache.hadoop.conf.Configuration cfg,
AbstractSerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI) |
protected |
PTFPartition(org.apache.hadoop.conf.Configuration cfg,
AbstractSerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI,
boolean createElemContainer) |
Modifier and Type | Method and Description |
---|---|
void |
append(Object o) |
void |
close() |
static PTFPartition |
create(org.apache.hadoop.conf.Configuration cfg,
AbstractSerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI) |
static PTFRollingPartition |
createRolling(org.apache.hadoop.conf.Configuration cfg,
AbstractSerDe serDe,
StructObjectInspector inputOI,
StructObjectInspector outputOI,
int precedingSpan,
int followingSpan) |
Object |
getAt(int i) |
StructObjectInspector |
getInputOI() |
StructObjectInspector |
getOutputOI() |
AbstractSerDe |
getSerDe() |
PTFPartition.PTFPartitionIterator<Object> |
iterator() |
PTFPartition.PTFPartitionIterator<Object> |
range(int start,
int end) |
void |
reset() |
static StructObjectInspector |
setupPartitionOutputOI(AbstractSerDe serDe,
StructObjectInspector tblFnOI) |
int |
size() |
protected PTFPartition(org.apache.hadoop.conf.Configuration cfg, AbstractSerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI) throws HiveException
HiveException
protected PTFPartition(org.apache.hadoop.conf.Configuration cfg, AbstractSerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, boolean createElemContainer) throws HiveException
HiveException
public void reset() throws HiveException
HiveException
public AbstractSerDe getSerDe()
public StructObjectInspector getInputOI()
public StructObjectInspector getOutputOI()
public Object getAt(int i) throws HiveException
HiveException
public void append(Object o) throws HiveException
HiveException
public int size()
public PTFPartition.PTFPartitionIterator<Object> iterator() throws HiveException
HiveException
public PTFPartition.PTFPartitionIterator<Object> range(int start, int end)
public void close()
public static PTFPartition create(org.apache.hadoop.conf.Configuration cfg, AbstractSerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI) throws HiveException
HiveException
public static PTFRollingPartition createRolling(org.apache.hadoop.conf.Configuration cfg, AbstractSerDe serDe, StructObjectInspector inputOI, StructObjectInspector outputOI, int precedingSpan, int followingSpan) throws HiveException
HiveException
public static StructObjectInspector setupPartitionOutputOI(AbstractSerDe serDe, StructObjectInspector tblFnOI) throws SerDeException
SerDeException
Copyright © 2021 The Apache Software Foundation. All rights reserved.