org.apache.flink.table.endpoint.hive.util

Class ThriftObjectConversions

java.lang.Object

org.apache.flink.table.endpoint.hive.util.ThriftObjectConversions

public class ThriftObjectConversions
extends Object

Conversion between thrift object and flink object.

Constructor Summary

Constructors

Constructor and Description
ThriftObjectConversions()

Method Summary

Modifier and Type	Method and Description
static org.apache.hive.service.rpc.thrift.TRowSet	toColumnBasedSet(List<LogicalType> fieldTypes, List<RowData.FieldGetter> fieldGetters, List<RowData> rows)
static FetchOrientation	toFetchOrientation(org.apache.hive.service.rpc.thrift.TFetchOrientation fetchOrientation)
static Set<CatalogBaseTable.TableKind>	toFlinkTableKinds(List<String> tableTypes) Counterpart of the org.apache.hive.service.cli.operation.TableTypeMapping.
static OperationHandle	toOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle tOperationHandle)
static org.apache.hive.service.rpc.thrift.TRowSet	toRowBasedSet(List<LogicalType> fieldTypes, List<RowData.FieldGetter> fieldGetters, List<RowData> rows)
static SessionHandle	toSessionHandle(org.apache.hive.service.rpc.thrift.TOperationHandle tOperationHandle)
static SessionHandle	toSessionHandle(org.apache.hive.service.rpc.thrift.TSessionHandle tSessionHandle)
static org.apache.hive.service.rpc.thrift.TOperationHandle	toTOperationHandle(SessionHandle sessionHandle, OperationHandle operationHandle, org.apache.hive.service.rpc.thrift.TOperationType operationType) Convert SessionHandle and OperationHandle to TOperationHandle.
static org.apache.hive.service.rpc.thrift.TOperationState	toTOperationState(OperationStatus operationStatus)
static org.apache.hive.service.rpc.thrift.TRowSet	toTRowSet(org.apache.hive.service.rpc.thrift.TProtocolVersion version, ResolvedSchema schema, List<RowData> data) Similar to SerDeUtils.toThriftPayload(Object, ObjectInspector, int) that converts the returned Rows to JSON string.
static org.apache.hive.service.rpc.thrift.TSessionHandle	toTSessionHandle(SessionHandle sessionHandle)
static org.apache.hive.service.rpc.thrift.TStatus	toTStatus(Throwable t)
static org.apache.hive.service.rpc.thrift.TTableSchema	toTTableSchema(ResolvedSchema schema) Similar logic in the org.apache.hive.service.cli.ColumnDescriptor.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThriftObjectConversions

public ThriftObjectConversions()

Method Detail

toTSessionHandle

public static org.apache.hive.service.rpc.thrift.TSessionHandle toTSessionHandle(SessionHandle sessionHandle)

toSessionHandle

public static SessionHandle toSessionHandle(org.apache.hive.service.rpc.thrift.TSessionHandle tSessionHandle)

toTOperationHandle

public static org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle(SessionHandle sessionHandle,
                                                                                     OperationHandle operationHandle,
                                                                                     org.apache.hive.service.rpc.thrift.TOperationType operationType)

Convert SessionHandle and OperationHandle to TOperationHandle.

Hive uses TOperationHandle to retrieve the Operation related information. However, SqlGateway uses SessionHandle and OperationHandle to determine. Therefore, the TOperationHandle needs to contain both SessionHandle and OperationHandle.

Currently all operations in the SqlGatewayService has data. Therefore, set the TOperationHandle#hasResultSet true.

toSessionHandle

public static SessionHandle toSessionHandle(org.apache.hive.service.rpc.thrift.TOperationHandle tOperationHandle)

toOperationHandle

public static OperationHandle toOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle tOperationHandle)

toTOperationState

public static org.apache.hive.service.rpc.thrift.TOperationState toTOperationState(OperationStatus operationStatus)

toFetchOrientation

public static FetchOrientation toFetchOrientation(org.apache.hive.service.rpc.thrift.TFetchOrientation fetchOrientation)

toTTableSchema

public static org.apache.hive.service.rpc.thrift.TTableSchema toTTableSchema(ResolvedSchema schema)

Similar logic in the org.apache.hive.service.cli.ColumnDescriptor.

toTRowSet

public static org.apache.hive.service.rpc.thrift.TRowSet toTRowSet(org.apache.hive.service.rpc.thrift.TProtocolVersion version,
                                                                   ResolvedSchema schema,
                                                                   List<RowData> data)

Similar to SerDeUtils.toThriftPayload(Object, ObjectInspector, int) that converts the returned Rows to JSON string. The only difference is the current implementation also keep the type for primitive type.

toFlinkTableKinds

public static Set<CatalogBaseTable.TableKind> toFlinkTableKinds(@Nullable
                                                                List<String> tableTypes)

Counterpart of the org.apache.hive.service.cli.operation.TableTypeMapping.

toTStatus

public static org.apache.hive.service.rpc.thrift.TStatus toTStatus(Throwable t)

toColumnBasedSet

@VisibleForTesting
public static org.apache.hive.service.rpc.thrift.TRowSet toColumnBasedSet(List<LogicalType> fieldTypes,
                                                                                             List<RowData.FieldGetter> fieldGetters,
                                                                                             List<RowData> rows)

toRowBasedSet

@VisibleForTesting
public static org.apache.hive.service.rpc.thrift.TRowSet toRowBasedSet(List<LogicalType> fieldTypes,
                                                                                          List<RowData.FieldGetter> fieldGetters,
                                                                                          List<RowData> rows)