org.apache.flink.table.planner.delegation.hive.operations

Class HiveLoadDataOperation

java.lang.Object

org.apache.flink.table.planner.delegation.hive.operations.HiveLoadDataOperation

All Implemented Interfaces:

Operation

public class HiveLoadDataOperation
extends Object
implements Operation

An operation that loads data into a Hive table.

The syntax is: 
 LOAD DATA [LOCAL] INPATH 'filepath' [OVERWRITE] INTO TABLE tablename
 [PARTITION (partcol1=val1, partcol2=val2 ...)]
 
 

Constructor Summary

Constructors

Constructor and Description
HiveLoadDataOperation(org.apache.hadoop.fs.Path path, ObjectPath tablePath, boolean isOverwrite, boolean isSrcLocal, Map<String,String> partitionSpec)

Method Summary

Modifier and Type	Method and Description
String	asSummaryString() Returns a string that summarizes this operation for printing to a console.
Map<String,String>	getPartitionSpec()
org.apache.hadoop.fs.Path	getPath()
ObjectPath	getTablePath()
boolean	isOverwrite()
boolean	isSrcLocal()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveLoadDataOperation

public HiveLoadDataOperation(org.apache.hadoop.fs.Path path,
                             ObjectPath tablePath,
                             boolean isOverwrite,
                             boolean isSrcLocal,
                             Map<String,String> partitionSpec)

Method Detail

getPath

public org.apache.hadoop.fs.Path getPath()

getTablePath

public ObjectPath getTablePath()

isOverwrite

public boolean isOverwrite()

isSrcLocal

public boolean isSrcLocal()

getPartitionSpec

public Map<String,String> getPartitionSpec()

asSummaryString

public String asSummaryString()

Description copied from interface: Operation

Returns a string that summarizes this operation for printing to a console. An implementation might skip very specific properties.

Specified by:

asSummaryString in interface Operation

Returns:

summary string of this operation for debugging purposes