diff --git a/thrift/TCLIService.d.ts b/thrift/TCLIService.d.ts index 5e254361..b9d4ec83 100644 --- a/thrift/TCLIService.d.ts +++ b/thrift/TCLIService.d.ts @@ -78,6 +78,7 @@ import TDBSqlTempView = ttypes.TDBSqlTempView import TDBSqlSessionCapabilities = ttypes.TDBSqlSessionCapabilities import TExpressionInfo = ttypes.TExpressionInfo import TDBSqlConfValue = ttypes.TDBSqlConfValue +import TSQLVariable = ttypes.TSQLVariable import TDBSqlSessionConf = ttypes.TDBSqlSessionConf import TStatus = ttypes.TStatus import TNamespace = ttypes.TNamespace @@ -97,6 +98,7 @@ import TSparkArrowTypes = ttypes.TSparkArrowTypes import TExecuteStatementReq = ttypes.TExecuteStatementReq import TDBSqlStatement = ttypes.TDBSqlStatement import TSparkParameterValue = ttypes.TSparkParameterValue +import TSparkParameterValueArg = ttypes.TSparkParameterValueArg import TSparkParameter = ttypes.TSparkParameter import TStatementConf = ttypes.TStatementConf import TExecuteStatementResp = ttypes.TExecuteStatementResp diff --git a/thrift/TCLIService_types.d.ts b/thrift/TCLIService_types.d.ts index fa242704..a49ab3cd 100644 --- a/thrift/TCLIService_types.d.ts +++ b/thrift/TCLIService_types.d.ts @@ -30,6 +30,7 @@ declare enum TProtocolVersion { SPARK_CLI_SERVICE_PROTOCOL_V6 = 42246, SPARK_CLI_SERVICE_PROTOCOL_V7 = 42247, SPARK_CLI_SERVICE_PROTOCOL_V8 = 42248, + SPARK_CLI_SERVICE_PROTOCOL_V9 = 42249, } declare enum TTypeId { @@ -177,6 +178,7 @@ declare enum TResultPersistenceMode { declare enum TDBSqlCloseOperationReason { NONE = 0, COMMAND_INACTIVITY_TIMEOUT = 1, + CLOSE_SESSION = 2, } declare enum TCacheLookupResult { @@ -195,6 +197,7 @@ declare enum TCloudFetchDisabledReason { SMALL_RESULT_SIZE = 5, CUSTOMER_STORAGE_SUPPORT = 6, UNKNOWN = 7, + METADATA_OPERATION = 8, } declare enum TDBSqlManifestFileFormat { @@ -501,9 +504,8 @@ declare class TRowSet { public columnCount?: number; public arrowBatches?: TSparkArrowBatch[]; public resultLinks?: TSparkArrowResultLink[]; - public cloudFetchResults?: TDBSqlCloudResultFile[]; - constructor(args?: { startRowOffset: Int64; rows: TRow[]; columns?: TColumn[]; binaryColumns?: Buffer; columnCount?: number; arrowBatches?: TSparkArrowBatch[]; resultLinks?: TSparkArrowResultLink[]; cloudFetchResults?: TDBSqlCloudResultFile[]; }); + constructor(args?: { startRowOffset: Int64; rows: TRow[]; columns?: TColumn[]; binaryColumns?: Buffer; columnCount?: number; arrowBatches?: TSparkArrowBatch[]; resultLinks?: TSparkArrowResultLink[]; }); } declare class TDBSqlTempView { @@ -544,6 +546,17 @@ declare class TDBSqlConfValue { constructor(args?: { value?: string; }); } +declare class TSQLVariable { + public catalogName?: string; + public schemaName?: string; + public variableName?: string; + public defaultExpressionSQL?: string; + public variableDataType?: string; + public currentValue?: string; + + constructor(args?: { catalogName?: string; schemaName?: string; variableName?: string; defaultExpressionSQL?: string; variableDataType?: string; currentValue?: string; }); +} + declare class TDBSqlSessionConf { public confs?: { [k: string]: string; }; public tempViews?: TDBSqlTempView[]; @@ -552,8 +565,9 @@ declare class TDBSqlSessionConf { public sessionCapabilities?: TDBSqlSessionCapabilities; public expressionsInfos?: TExpressionInfo[]; public internalConfs?: { [k: string]: TDBSqlConfValue; }; + public tempVariables?: TSQLVariable[]; - constructor(args?: { confs?: { [k: string]: string; }; tempViews?: TDBSqlTempView[]; currentDatabase?: string; currentCatalog?: string; sessionCapabilities?: TDBSqlSessionCapabilities; expressionsInfos?: TExpressionInfo[]; internalConfs?: { [k: string]: TDBSqlConfValue; }; }); + constructor(args?: { confs?: { [k: string]: string; }; tempViews?: TDBSqlTempView[]; currentDatabase?: string; currentCatalog?: string; sessionCapabilities?: TDBSqlSessionCapabilities; expressionsInfos?: TExpressionInfo[]; internalConfs?: { [k: string]: TDBSqlConfValue; }; tempVariables?: TSQLVariable[]; }); } declare class TStatus { @@ -564,9 +578,8 @@ declare class TStatus { public errorMessage?: string; public displayMessage?: string; public errorDetailsJson?: string; - public responseValidation?: Buffer; - constructor(args?: { statusCode: TStatusCode; infoMessages?: string[]; sqlState?: string; errorCode?: number; errorMessage?: string; displayMessage?: string; errorDetailsJson?: string; responseValidation?: Buffer; }); + constructor(args?: { statusCode: TStatusCode; infoMessages?: string[]; sqlState?: string; errorCode?: number; errorMessage?: string; displayMessage?: string; errorDetailsJson?: string; }); } declare class TNamespace { @@ -579,16 +592,14 @@ declare class TNamespace { declare class THandleIdentifier { public guid: Buffer; public secret: Buffer; - public executionVersion?: number; - constructor(args?: { guid: Buffer; secret: Buffer; executionVersion?: number; }); + constructor(args?: { guid: Buffer; secret: Buffer; }); } declare class TSessionHandle { public sessionId: THandleIdentifier; - public serverProtocolVersion?: TProtocolVersion; - constructor(args?: { sessionId: THandleIdentifier; serverProtocolVersion?: TProtocolVersion; }); + constructor(args?: { sessionId: THandleIdentifier; }); } declare class TOperationHandle { @@ -610,9 +621,8 @@ declare class TOpenSessionReq { public connectionProperties?: { [k: string]: string; }; public initialNamespace?: TNamespace; public canUseMultipleCatalogs?: boolean; - public sessionId?: THandleIdentifier; - constructor(args?: { client_protocol?: TProtocolVersion; username?: string; password?: string; configuration?: { [k: string]: string; }; getInfos?: TGetInfoType[]; client_protocol_i64?: Int64; connectionProperties?: { [k: string]: string; }; initialNamespace?: TNamespace; canUseMultipleCatalogs?: boolean; sessionId?: THandleIdentifier; }); + constructor(args?: { client_protocol?: TProtocolVersion; username?: string; password?: string; configuration?: { [k: string]: string; }; getInfos?: TGetInfoType[]; client_protocol_i64?: Int64; connectionProperties?: { [k: string]: string; }; initialNamespace?: TNamespace; canUseMultipleCatalogs?: boolean; }); } declare class TOpenSessionResp { @@ -653,9 +663,8 @@ declare class TGetInfoValue { declare class TGetInfoReq { public sessionHandle: TSessionHandle; public infoType: TGetInfoType; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; infoType: TGetInfoType; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; infoType: TGetInfoType; }); } declare class TGetInfoResp { @@ -707,29 +716,8 @@ declare class TExecuteStatementReq { public parameters?: TSparkParameter[]; public maxBytesPerBatch?: Int64; public statementConf?: TStatementConf; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - public rejectHighCostQueries?: boolean; - public estimatedCost?: number; - public executionVersion?: number; - public requestValidation?: Buffer; - public resultPersistenceMode?: TResultPersistenceMode; - public trimArrowBatchesToLimit?: boolean; - public fetchDisposition?: TDBSqlFetchDisposition; - public enforceResultPersistenceMode?: boolean; - public statementList?: TDBSqlStatement[]; - public persistResultManifest?: boolean; - public resultRetentionSeconds?: Int64; - public resultByteLimit?: Int64; - public resultDataFormat?: TDBSqlResultFormat; - public originatingClientIdentity?: string; - public preferSingleFileResult?: boolean; - public preferDriverOnlyUpload?: boolean; - public enforceEmbeddedSchemaCorrectness?: boolean; - public idempotencyToken?: string; - public throwErrorOnByteLimitTruncation?: boolean; - - constructor(args?: { sessionHandle: TSessionHandle; statement: string; confOverlay?: { [k: string]: string; }; runAsync?: boolean; getDirectResults?: TSparkGetDirectResults; queryTimeout?: Int64; canReadArrowResult?: boolean; canDownloadResult?: boolean; canDecompressLZ4Result?: boolean; maxBytesPerFile?: Int64; useArrowNativeTypes?: TSparkArrowTypes; resultRowLimit?: Int64; parameters?: TSparkParameter[]; maxBytesPerBatch?: Int64; statementConf?: TStatementConf; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; rejectHighCostQueries?: boolean; estimatedCost?: number; executionVersion?: number; requestValidation?: Buffer; resultPersistenceMode?: TResultPersistenceMode; trimArrowBatchesToLimit?: boolean; fetchDisposition?: TDBSqlFetchDisposition; enforceResultPersistenceMode?: boolean; statementList?: TDBSqlStatement[]; persistResultManifest?: boolean; resultRetentionSeconds?: Int64; resultByteLimit?: Int64; resultDataFormat?: TDBSqlResultFormat; originatingClientIdentity?: string; preferSingleFileResult?: boolean; preferDriverOnlyUpload?: boolean; enforceEmbeddedSchemaCorrectness?: boolean; idempotencyToken?: string; throwErrorOnByteLimitTruncation?: boolean; }); + + constructor(args?: { sessionHandle: TSessionHandle; statement: string; confOverlay?: { [k: string]: string; }; runAsync?: boolean; getDirectResults?: TSparkGetDirectResults; queryTimeout?: Int64; canReadArrowResult?: boolean; canDownloadResult?: boolean; canDecompressLZ4Result?: boolean; maxBytesPerFile?: Int64; useArrowNativeTypes?: TSparkArrowTypes; resultRowLimit?: Int64; parameters?: TSparkParameter[]; maxBytesPerBatch?: Int64; statementConf?: TStatementConf; }); } declare class TDBSqlStatement { @@ -746,13 +734,22 @@ declare class TSparkParameterValue { constructor(args?: { stringValue?: string; doubleValue?: number; booleanValue?: boolean; }); } +declare class TSparkParameterValueArg { + public type?: string; + public value?: string; + public arguments?: TSparkParameterValueArg[]; + + constructor(args?: { type?: string; value?: string; arguments?: TSparkParameterValueArg[]; }); +} + declare class TSparkParameter { public ordinal?: number; public name?: string; public type?: string; public value?: TSparkParameterValue; + public arguments?: TSparkParameterValueArg[]; - constructor(args?: { ordinal?: number; name?: string; type?: string; value?: TSparkParameterValue; }); + constructor(args?: { ordinal?: number; name?: string; type?: string; value?: TSparkParameterValue; arguments?: TSparkParameterValueArg[]; }); } declare class TStatementConf { @@ -768,27 +765,16 @@ declare class TExecuteStatementResp { public status: TStatus; public operationHandle?: TOperationHandle; public directResults?: TSparkDirectResults; - public executionRejected?: boolean; - public maxClusterCapacity?: number; - public queryCost?: number; - public sessionConf?: TDBSqlSessionConf; - public currentClusterLoad?: number; - public idempotencyType?: TOperationIdempotencyType; - public remoteResultCacheEnabled?: boolean; - public isServerless?: boolean; - public operationHandles?: TOperationHandle[]; - constructor(args?: { status: TStatus; operationHandle?: TOperationHandle; directResults?: TSparkDirectResults; executionRejected?: boolean; maxClusterCapacity?: number; queryCost?: number; sessionConf?: TDBSqlSessionConf; currentClusterLoad?: number; idempotencyType?: TOperationIdempotencyType; remoteResultCacheEnabled?: boolean; isServerless?: boolean; operationHandles?: TOperationHandle[]; }); + constructor(args?: { status: TStatus; operationHandle?: TOperationHandle; directResults?: TSparkDirectResults; }); } declare class TGetTypeInfoReq { public sessionHandle: TSessionHandle; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetTypeInfoResp { @@ -803,10 +789,8 @@ declare class TGetCatalogsReq { public sessionHandle: TSessionHandle; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetCatalogsResp { @@ -823,10 +807,8 @@ declare class TGetSchemasReq { public schemaName?: string; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetSchemasResp { @@ -845,10 +827,8 @@ declare class TGetTablesReq { public tableTypes?: string[]; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; tableName?: string; tableTypes?: string[]; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; tableName?: string; tableTypes?: string[]; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetTablesResp { @@ -863,10 +843,8 @@ declare class TGetTableTypesReq { public sessionHandle: TSessionHandle; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetTableTypesResp { @@ -885,10 +863,8 @@ declare class TGetColumnsReq { public columnName?: string; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; tableName?: string; columnName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; tableName?: string; columnName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetColumnsResp { @@ -906,10 +882,8 @@ declare class TGetFunctionsReq { public functionName: string; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; functionName: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; functionName: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetFunctionsResp { @@ -927,10 +901,8 @@ declare class TGetPrimaryKeysReq { public tableName?: string; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; tableName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; catalogName?: string; schemaName?: string; tableName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetPrimaryKeysResp { @@ -951,10 +923,8 @@ declare class TGetCrossReferenceReq { public foreignTableName?: string; public getDirectResults?: TSparkGetDirectResults; public runAsync?: boolean; - public operationId?: THandleIdentifier; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; parentCatalogName?: string; parentSchemaName?: string; parentTableName?: string; foreignCatalogName?: string; foreignSchemaName?: string; foreignTableName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; operationId?: THandleIdentifier; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; parentCatalogName?: string; parentSchemaName?: string; parentTableName?: string; foreignCatalogName?: string; foreignSchemaName?: string; foreignTableName?: string; getDirectResults?: TSparkGetDirectResults; runAsync?: boolean; }); } declare class TGetCrossReferenceResp { @@ -987,20 +957,14 @@ declare class TGetOperationStatusResp { public displayMessage?: string; public diagnosticInfo?: string; public errorDetailsJson?: string; - public responseValidation?: Buffer; - public idempotencyType?: TOperationIdempotencyType; - public statementTimeout?: Int64; - public statementTimeoutLevel?: TOperationTimeoutLevel; - constructor(args?: { status: TStatus; operationState?: TOperationState; sqlState?: string; errorCode?: number; errorMessage?: string; taskStatus?: string; operationStarted?: Int64; operationCompleted?: Int64; hasResultSet?: boolean; progressUpdateResponse?: TProgressUpdateResp; numModifiedRows?: Int64; displayMessage?: string; diagnosticInfo?: string; errorDetailsJson?: string; responseValidation?: Buffer; idempotencyType?: TOperationIdempotencyType; statementTimeout?: Int64; statementTimeoutLevel?: TOperationTimeoutLevel; }); + constructor(args?: { status: TStatus; operationState?: TOperationState; sqlState?: string; errorCode?: number; errorMessage?: string; taskStatus?: string; operationStarted?: Int64; operationCompleted?: Int64; hasResultSet?: boolean; progressUpdateResponse?: TProgressUpdateResp; numModifiedRows?: Int64; displayMessage?: string; diagnosticInfo?: string; errorDetailsJson?: string; }); } declare class TCancelOperationReq { public operationHandle: TOperationHandle; - public executionVersion?: number; - public replacedByNextAttempt?: boolean; - constructor(args?: { operationHandle: TOperationHandle; executionVersion?: number; replacedByNextAttempt?: boolean; }); + constructor(args?: { operationHandle: TOperationHandle; }); } declare class TCancelOperationResp { @@ -1011,9 +975,8 @@ declare class TCancelOperationResp { declare class TCloseOperationReq { public operationHandle: TOperationHandle; - public closeReason?: TDBSqlCloseOperationReason; - constructor(args?: { operationHandle: TOperationHandle; closeReason?: TDBSqlCloseOperationReason; }); + constructor(args?: { operationHandle: TOperationHandle; }); } declare class TCloseOperationResp { @@ -1024,9 +987,8 @@ declare class TCloseOperationResp { declare class TGetResultSetMetadataReq { public operationHandle: TOperationHandle; - public includeCloudResultFiles?: boolean; - constructor(args?: { operationHandle: TOperationHandle; includeCloudResultFiles?: boolean; }); + constructor(args?: { operationHandle: TOperationHandle; }); } declare class TGetResultSetMetadataResp { @@ -1039,20 +1001,8 @@ declare class TGetResultSetMetadataResp { public uncompressedBytes?: Int64; public compressedBytes?: Int64; public isStagingOperation?: boolean; - public reasonForNoCloudFetch?: TCloudFetchDisabledReason; - public resultFiles?: TDBSqlCloudResultFile[]; - public manifestFile?: string; - public manifestFileFormat?: TDBSqlManifestFileFormat; - public cacheLookupLatency?: Int64; - public remoteCacheMissReason?: string; - public fetchDisposition?: TDBSqlFetchDisposition; - public remoteResultCacheEnabled?: boolean; - public isServerless?: boolean; - public resultDataFormat?: TDBSqlResultFormat; - public truncatedByThriftLimit?: boolean; - public resultByteLimit?: Int64; - - constructor(args?: { status: TStatus; schema?: TTableSchema; resultFormat?: TSparkRowSetType; lz4Compressed?: boolean; arrowSchema?: Buffer; cacheLookupResult?: TCacheLookupResult; uncompressedBytes?: Int64; compressedBytes?: Int64; isStagingOperation?: boolean; reasonForNoCloudFetch?: TCloudFetchDisabledReason; resultFiles?: TDBSqlCloudResultFile[]; manifestFile?: string; manifestFileFormat?: TDBSqlManifestFileFormat; cacheLookupLatency?: Int64; remoteCacheMissReason?: string; fetchDisposition?: TDBSqlFetchDisposition; remoteResultCacheEnabled?: boolean; isServerless?: boolean; resultDataFormat?: TDBSqlResultFormat; truncatedByThriftLimit?: boolean; resultByteLimit?: Int64; }); + + constructor(args?: { status: TStatus; schema?: TTableSchema; resultFormat?: TSparkRowSetType; lz4Compressed?: boolean; arrowSchema?: Buffer; cacheLookupResult?: TCacheLookupResult; uncompressedBytes?: Int64; compressedBytes?: Int64; isStagingOperation?: boolean; }); } declare class TFetchResultsReq { @@ -1072,18 +1022,16 @@ declare class TFetchResultsResp { public hasMoreRows?: boolean; public results?: TRowSet; public resultSetMetadata?: TGetResultSetMetadataResp; - public responseValidation?: Buffer; - constructor(args?: { status: TStatus; hasMoreRows?: boolean; results?: TRowSet; resultSetMetadata?: TGetResultSetMetadataResp; responseValidation?: Buffer; }); + constructor(args?: { status: TStatus; hasMoreRows?: boolean; results?: TRowSet; resultSetMetadata?: TGetResultSetMetadataResp; }); } declare class TGetDelegationTokenReq { public sessionHandle: TSessionHandle; public owner: string; public renewer: string; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; owner: string; renewer: string; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; owner: string; renewer: string; }); } declare class TGetDelegationTokenResp { @@ -1096,9 +1044,8 @@ declare class TGetDelegationTokenResp { declare class TCancelDelegationTokenReq { public sessionHandle: TSessionHandle; public delegationToken: string; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; delegationToken: string; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; delegationToken: string; }); } declare class TCancelDelegationTokenResp { @@ -1110,9 +1057,8 @@ declare class TCancelDelegationTokenResp { declare class TRenewDelegationTokenReq { public sessionHandle: TSessionHandle; public delegationToken: string; - public sessionConf?: TDBSqlSessionConf; - constructor(args?: { sessionHandle: TSessionHandle; delegationToken: string; sessionConf?: TDBSqlSessionConf; }); + constructor(args?: { sessionHandle: TSessionHandle; delegationToken: string; }); } declare class TRenewDelegationTokenResp { diff --git a/thrift/TCLIService_types.js b/thrift/TCLIService_types.js index 7eb913e2..e14349cd 100644 --- a/thrift/TCLIService_types.js +++ b/thrift/TCLIService_types.js @@ -52,7 +52,9 @@ ttypes.TProtocolVersion = { '42247' : 'SPARK_CLI_SERVICE_PROTOCOL_V7', 'SPARK_CLI_SERVICE_PROTOCOL_V7' : 42247, '42248' : 'SPARK_CLI_SERVICE_PROTOCOL_V8', - 'SPARK_CLI_SERVICE_PROTOCOL_V8' : 42248 + 'SPARK_CLI_SERVICE_PROTOCOL_V8' : 42248, + '42249' : 'SPARK_CLI_SERVICE_PROTOCOL_V9', + 'SPARK_CLI_SERVICE_PROTOCOL_V9' : 42249 }; ttypes.TTypeId = { '0' : 'BOOLEAN_TYPE', @@ -298,7 +300,9 @@ ttypes.TDBSqlCloseOperationReason = { '0' : 'NONE', 'NONE' : 0, '1' : 'COMMAND_INACTIVITY_TIMEOUT', - 'COMMAND_INACTIVITY_TIMEOUT' : 1 + 'COMMAND_INACTIVITY_TIMEOUT' : 1, + '2' : 'CLOSE_SESSION', + 'CLOSE_SESSION' : 2 }; ttypes.TCacheLookupResult = { '0' : 'CACHE_INELIGIBLE', @@ -326,7 +330,9 @@ ttypes.TCloudFetchDisabledReason = { '6' : 'CUSTOMER_STORAGE_SUPPORT', 'CUSTOMER_STORAGE_SUPPORT' : 6, '7' : 'UNKNOWN', - 'UNKNOWN' : 7 + 'UNKNOWN' : 7, + '8' : 'METADATA_OPERATION', + 'METADATA_OPERATION' : 8 }; ttypes.TDBSqlManifestFileFormat = { '0' : 'THRIFT_GET_RESULT_SET_METADATA_RESP', @@ -3289,7 +3295,6 @@ var TRowSet = module.exports.TRowSet = function(args) { this.columnCount = null; this.arrowBatches = null; this.resultLinks = null; - this.cloudFetchResults = null; if (args) { if (args.startRowOffset !== undefined && args.startRowOffset !== null) { this.startRowOffset = args.startRowOffset; @@ -3316,9 +3321,6 @@ var TRowSet = module.exports.TRowSet = function(args) { if (args.resultLinks !== undefined && args.resultLinks !== null) { this.resultLinks = Thrift.copyList(args.resultLinks, [ttypes.TSparkArrowResultLink]); } - if (args.cloudFetchResults !== undefined && args.cloudFetchResults !== null) { - this.cloudFetchResults = Thrift.copyList(args.cloudFetchResults, [ttypes.TDBSqlCloudResultFile]); - } } }; TRowSet.prototype = {}; @@ -3417,22 +3419,6 @@ TRowSet.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.LIST) { - this.cloudFetchResults = []; - var _rtmp3107 = input.readListBegin(); - var _size106 = _rtmp3107.size || 0; - for (var _i108 = 0; _i108 < _size106; ++_i108) { - var elem109 = null; - elem109 = new ttypes.TDBSqlCloudResultFile(); - elem109.read(input); - this.cloudFetchResults.push(elem109); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -3452,10 +3438,10 @@ TRowSet.prototype.write = function(output) { if (this.rows !== null && this.rows !== undefined) { output.writeFieldBegin('rows', Thrift.Type.LIST, 2); output.writeListBegin(Thrift.Type.STRUCT, this.rows.length); - for (var iter110 in this.rows) { - if (this.rows.hasOwnProperty(iter110)) { - iter110 = this.rows[iter110]; - iter110.write(output); + for (var iter106 in this.rows) { + if (this.rows.hasOwnProperty(iter106)) { + iter106 = this.rows[iter106]; + iter106.write(output); } } output.writeListEnd(); @@ -3464,10 +3450,10 @@ TRowSet.prototype.write = function(output) { if (this.columns !== null && this.columns !== undefined) { output.writeFieldBegin('columns', Thrift.Type.LIST, 3); output.writeListBegin(Thrift.Type.STRUCT, this.columns.length); - for (var iter111 in this.columns) { - if (this.columns.hasOwnProperty(iter111)) { - iter111 = this.columns[iter111]; - iter111.write(output); + for (var iter107 in this.columns) { + if (this.columns.hasOwnProperty(iter107)) { + iter107 = this.columns[iter107]; + iter107.write(output); } } output.writeListEnd(); @@ -3486,10 +3472,10 @@ TRowSet.prototype.write = function(output) { if (this.arrowBatches !== null && this.arrowBatches !== undefined) { output.writeFieldBegin('arrowBatches', Thrift.Type.LIST, 1281); output.writeListBegin(Thrift.Type.STRUCT, this.arrowBatches.length); - for (var iter112 in this.arrowBatches) { - if (this.arrowBatches.hasOwnProperty(iter112)) { - iter112 = this.arrowBatches[iter112]; - iter112.write(output); + for (var iter108 in this.arrowBatches) { + if (this.arrowBatches.hasOwnProperty(iter108)) { + iter108 = this.arrowBatches[iter108]; + iter108.write(output); } } output.writeListEnd(); @@ -3498,22 +3484,10 @@ TRowSet.prototype.write = function(output) { if (this.resultLinks !== null && this.resultLinks !== undefined) { output.writeFieldBegin('resultLinks', Thrift.Type.LIST, 1282); output.writeListBegin(Thrift.Type.STRUCT, this.resultLinks.length); - for (var iter113 in this.resultLinks) { - if (this.resultLinks.hasOwnProperty(iter113)) { - iter113 = this.resultLinks[iter113]; - iter113.write(output); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } - if (this.cloudFetchResults !== null && this.cloudFetchResults !== undefined) { - output.writeFieldBegin('cloudFetchResults', Thrift.Type.LIST, 3329); - output.writeListBegin(Thrift.Type.STRUCT, this.cloudFetchResults.length); - for (var iter114 in this.cloudFetchResults) { - if (this.cloudFetchResults.hasOwnProperty(iter114)) { - iter114 = this.cloudFetchResults[iter114]; - iter114.write(output); + for (var iter109 in this.resultLinks) { + if (this.resultLinks.hasOwnProperty(iter109)) { + iter109 = this.resultLinks[iter109]; + iter109.write(output); } } output.writeListEnd(); @@ -3572,14 +3546,14 @@ TDBSqlTempView.prototype.read = function(input) { case 3: if (ftype == Thrift.Type.MAP) { this.properties = {}; - var _rtmp3116 = input.readMapBegin(); - var _size115 = _rtmp3116.size || 0; - for (var _i117 = 0; _i117 < _size115; ++_i117) { - var key118 = null; - var val119 = null; - key118 = input.readString(); - val119 = input.readString(); - this.properties[key118] = val119; + var _rtmp3111 = input.readMapBegin(); + var _size110 = _rtmp3111.size || 0; + for (var _i112 = 0; _i112 < _size110; ++_i112) { + var key113 = null; + var val114 = null; + key113 = input.readString(); + val114 = input.readString(); + this.properties[key113] = val114; } input.readMapEnd(); } else { @@ -3617,11 +3591,11 @@ TDBSqlTempView.prototype.write = function(output) { if (this.properties !== null && this.properties !== undefined) { output.writeFieldBegin('properties', Thrift.Type.MAP, 3); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.properties)); - for (var kiter120 in this.properties) { - if (this.properties.hasOwnProperty(kiter120)) { - var viter121 = this.properties[kiter120]; - output.writeString(kiter120); - output.writeString(viter121); + for (var kiter115 in this.properties) { + if (this.properties.hasOwnProperty(kiter115)) { + var viter116 = this.properties[kiter115]; + output.writeString(kiter115); + output.writeString(viter116); } } output.writeMapEnd(); @@ -3960,6 +3934,133 @@ TDBSqlConfValue.prototype.write = function(output) { return; }; +var TSQLVariable = module.exports.TSQLVariable = function(args) { + this.catalogName = null; + this.schemaName = null; + this.variableName = null; + this.defaultExpressionSQL = null; + this.variableDataType = null; + this.currentValue = null; + if (args) { + if (args.catalogName !== undefined && args.catalogName !== null) { + this.catalogName = args.catalogName; + } + if (args.schemaName !== undefined && args.schemaName !== null) { + this.schemaName = args.schemaName; + } + if (args.variableName !== undefined && args.variableName !== null) { + this.variableName = args.variableName; + } + if (args.defaultExpressionSQL !== undefined && args.defaultExpressionSQL !== null) { + this.defaultExpressionSQL = args.defaultExpressionSQL; + } + if (args.variableDataType !== undefined && args.variableDataType !== null) { + this.variableDataType = args.variableDataType; + } + if (args.currentValue !== undefined && args.currentValue !== null) { + this.currentValue = args.currentValue; + } + } +}; +TSQLVariable.prototype = {}; +TSQLVariable.prototype.read = function(input) { + input.readStructBegin(); + while (true) { + var ret = input.readFieldBegin(); + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) { + case 1: + if (ftype == Thrift.Type.STRING) { + this.catalogName = input.readString(); + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.schemaName = input.readString(); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.STRING) { + this.variableName = input.readString(); + } else { + input.skip(ftype); + } + break; + case 4: + if (ftype == Thrift.Type.STRING) { + this.defaultExpressionSQL = input.readString(); + } else { + input.skip(ftype); + } + break; + case 5: + if (ftype == Thrift.Type.STRING) { + this.variableDataType = input.readString(); + } else { + input.skip(ftype); + } + break; + case 6: + if (ftype == Thrift.Type.STRING) { + this.currentValue = input.readString(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +TSQLVariable.prototype.write = function(output) { + output.writeStructBegin('TSQLVariable'); + if (this.catalogName !== null && this.catalogName !== undefined) { + output.writeFieldBegin('catalogName', Thrift.Type.STRING, 1); + output.writeString(this.catalogName); + output.writeFieldEnd(); + } + if (this.schemaName !== null && this.schemaName !== undefined) { + output.writeFieldBegin('schemaName', Thrift.Type.STRING, 2); + output.writeString(this.schemaName); + output.writeFieldEnd(); + } + if (this.variableName !== null && this.variableName !== undefined) { + output.writeFieldBegin('variableName', Thrift.Type.STRING, 3); + output.writeString(this.variableName); + output.writeFieldEnd(); + } + if (this.defaultExpressionSQL !== null && this.defaultExpressionSQL !== undefined) { + output.writeFieldBegin('defaultExpressionSQL', Thrift.Type.STRING, 4); + output.writeString(this.defaultExpressionSQL); + output.writeFieldEnd(); + } + if (this.variableDataType !== null && this.variableDataType !== undefined) { + output.writeFieldBegin('variableDataType', Thrift.Type.STRING, 5); + output.writeString(this.variableDataType); + output.writeFieldEnd(); + } + if (this.currentValue !== null && this.currentValue !== undefined) { + output.writeFieldBegin('currentValue', Thrift.Type.STRING, 6); + output.writeString(this.currentValue); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + var TDBSqlSessionConf = module.exports.TDBSqlSessionConf = function(args) { this.confs = null; this.tempViews = null; @@ -3968,6 +4069,7 @@ var TDBSqlSessionConf = module.exports.TDBSqlSessionConf = function(args) { this.sessionCapabilities = null; this.expressionsInfos = null; this.internalConfs = null; + this.tempVariables = null; if (args) { if (args.confs !== undefined && args.confs !== null) { this.confs = Thrift.copyMap(args.confs, [null]); @@ -3990,6 +4092,9 @@ var TDBSqlSessionConf = module.exports.TDBSqlSessionConf = function(args) { if (args.internalConfs !== undefined && args.internalConfs !== null) { this.internalConfs = Thrift.copyMap(args.internalConfs, [ttypes.TDBSqlConfValue]); } + if (args.tempVariables !== undefined && args.tempVariables !== null) { + this.tempVariables = Thrift.copyList(args.tempVariables, [ttypes.TSQLVariable]); + } } }; TDBSqlSessionConf.prototype = {}; @@ -4006,14 +4111,14 @@ TDBSqlSessionConf.prototype.read = function(input) { case 1: if (ftype == Thrift.Type.MAP) { this.confs = {}; - var _rtmp3123 = input.readMapBegin(); - var _size122 = _rtmp3123.size || 0; - for (var _i124 = 0; _i124 < _size122; ++_i124) { - var key125 = null; - var val126 = null; - key125 = input.readString(); - val126 = input.readString(); - this.confs[key125] = val126; + var _rtmp3118 = input.readMapBegin(); + var _size117 = _rtmp3118.size || 0; + for (var _i119 = 0; _i119 < _size117; ++_i119) { + var key120 = null; + var val121 = null; + key120 = input.readString(); + val121 = input.readString(); + this.confs[key120] = val121; } input.readMapEnd(); } else { @@ -4023,13 +4128,13 @@ TDBSqlSessionConf.prototype.read = function(input) { case 2: if (ftype == Thrift.Type.LIST) { this.tempViews = []; - var _rtmp3128 = input.readListBegin(); - var _size127 = _rtmp3128.size || 0; - for (var _i129 = 0; _i129 < _size127; ++_i129) { - var elem130 = null; - elem130 = new ttypes.TDBSqlTempView(); - elem130.read(input); - this.tempViews.push(elem130); + var _rtmp3123 = input.readListBegin(); + var _size122 = _rtmp3123.size || 0; + for (var _i124 = 0; _i124 < _size122; ++_i124) { + var elem125 = null; + elem125 = new ttypes.TDBSqlTempView(); + elem125.read(input); + this.tempViews.push(elem125); } input.readListEnd(); } else { @@ -4061,13 +4166,13 @@ TDBSqlSessionConf.prototype.read = function(input) { case 6: if (ftype == Thrift.Type.LIST) { this.expressionsInfos = []; - var _rtmp3132 = input.readListBegin(); - var _size131 = _rtmp3132.size || 0; - for (var _i133 = 0; _i133 < _size131; ++_i133) { - var elem134 = null; - elem134 = new ttypes.TExpressionInfo(); - elem134.read(input); - this.expressionsInfos.push(elem134); + var _rtmp3127 = input.readListBegin(); + var _size126 = _rtmp3127.size || 0; + for (var _i128 = 0; _i128 < _size126; ++_i128) { + var elem129 = null; + elem129 = new ttypes.TExpressionInfo(); + elem129.read(input); + this.expressionsInfos.push(elem129); } input.readListEnd(); } else { @@ -4077,17 +4182,33 @@ TDBSqlSessionConf.prototype.read = function(input) { case 7: if (ftype == Thrift.Type.MAP) { this.internalConfs = {}; - var _rtmp3136 = input.readMapBegin(); + var _rtmp3131 = input.readMapBegin(); + var _size130 = _rtmp3131.size || 0; + for (var _i132 = 0; _i132 < _size130; ++_i132) { + var key133 = null; + var val134 = null; + key133 = input.readString(); + val134 = new ttypes.TDBSqlConfValue(); + val134.read(input); + this.internalConfs[key133] = val134; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 8: + if (ftype == Thrift.Type.LIST) { + this.tempVariables = []; + var _rtmp3136 = input.readListBegin(); var _size135 = _rtmp3136.size || 0; for (var _i137 = 0; _i137 < _size135; ++_i137) { - var key138 = null; - var val139 = null; - key138 = input.readString(); - val139 = new ttypes.TDBSqlConfValue(); - val139.read(input); - this.internalConfs[key138] = val139; + var elem138 = null; + elem138 = new ttypes.TSQLVariable(); + elem138.read(input); + this.tempVariables.push(elem138); } - input.readMapEnd(); + input.readListEnd(); } else { input.skip(ftype); } @@ -4106,11 +4227,11 @@ TDBSqlSessionConf.prototype.write = function(output) { if (this.confs !== null && this.confs !== undefined) { output.writeFieldBegin('confs', Thrift.Type.MAP, 1); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.confs)); - for (var kiter140 in this.confs) { - if (this.confs.hasOwnProperty(kiter140)) { - var viter141 = this.confs[kiter140]; - output.writeString(kiter140); - output.writeString(viter141); + for (var kiter139 in this.confs) { + if (this.confs.hasOwnProperty(kiter139)) { + var viter140 = this.confs[kiter139]; + output.writeString(kiter139); + output.writeString(viter140); } } output.writeMapEnd(); @@ -4119,10 +4240,10 @@ TDBSqlSessionConf.prototype.write = function(output) { if (this.tempViews !== null && this.tempViews !== undefined) { output.writeFieldBegin('tempViews', Thrift.Type.LIST, 2); output.writeListBegin(Thrift.Type.STRUCT, this.tempViews.length); - for (var iter142 in this.tempViews) { - if (this.tempViews.hasOwnProperty(iter142)) { - iter142 = this.tempViews[iter142]; - iter142.write(output); + for (var iter141 in this.tempViews) { + if (this.tempViews.hasOwnProperty(iter141)) { + iter141 = this.tempViews[iter141]; + iter141.write(output); } } output.writeListEnd(); @@ -4146,10 +4267,10 @@ TDBSqlSessionConf.prototype.write = function(output) { if (this.expressionsInfos !== null && this.expressionsInfos !== undefined) { output.writeFieldBegin('expressionsInfos', Thrift.Type.LIST, 6); output.writeListBegin(Thrift.Type.STRUCT, this.expressionsInfos.length); - for (var iter143 in this.expressionsInfos) { - if (this.expressionsInfos.hasOwnProperty(iter143)) { - iter143 = this.expressionsInfos[iter143]; - iter143.write(output); + for (var iter142 in this.expressionsInfos) { + if (this.expressionsInfos.hasOwnProperty(iter142)) { + iter142 = this.expressionsInfos[iter142]; + iter142.write(output); } } output.writeListEnd(); @@ -4158,16 +4279,28 @@ TDBSqlSessionConf.prototype.write = function(output) { if (this.internalConfs !== null && this.internalConfs !== undefined) { output.writeFieldBegin('internalConfs', Thrift.Type.MAP, 7); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.internalConfs)); - for (var kiter144 in this.internalConfs) { - if (this.internalConfs.hasOwnProperty(kiter144)) { - var viter145 = this.internalConfs[kiter144]; - output.writeString(kiter144); - viter145.write(output); + for (var kiter143 in this.internalConfs) { + if (this.internalConfs.hasOwnProperty(kiter143)) { + var viter144 = this.internalConfs[kiter143]; + output.writeString(kiter143); + viter144.write(output); } } output.writeMapEnd(); output.writeFieldEnd(); } + if (this.tempVariables !== null && this.tempVariables !== undefined) { + output.writeFieldBegin('tempVariables', Thrift.Type.LIST, 8); + output.writeListBegin(Thrift.Type.STRUCT, this.tempVariables.length); + for (var iter145 in this.tempVariables) { + if (this.tempVariables.hasOwnProperty(iter145)) { + iter145 = this.tempVariables[iter145]; + iter145.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } output.writeFieldStop(); output.writeStructEnd(); return; @@ -4181,7 +4314,6 @@ var TStatus = module.exports.TStatus = function(args) { this.errorMessage = null; this.displayMessage = null; this.errorDetailsJson = null; - this.responseValidation = null; if (args) { if (args.statusCode !== undefined && args.statusCode !== null) { this.statusCode = args.statusCode; @@ -4206,9 +4338,6 @@ var TStatus = module.exports.TStatus = function(args) { if (args.errorDetailsJson !== undefined && args.errorDetailsJson !== null) { this.errorDetailsJson = args.errorDetailsJson; } - if (args.responseValidation !== undefined && args.responseValidation !== null) { - this.responseValidation = args.responseValidation; - } } }; TStatus.prototype = {}; @@ -4279,13 +4408,6 @@ TStatus.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRING) { - this.responseValidation = input.readBinary(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -4339,11 +4461,6 @@ TStatus.prototype.write = function(output) { output.writeString(this.errorDetailsJson); output.writeFieldEnd(); } - if (this.responseValidation !== null && this.responseValidation !== undefined) { - output.writeFieldBegin('responseValidation', Thrift.Type.STRING, 3329); - output.writeBinary(this.responseValidation); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -4415,7 +4532,6 @@ TNamespace.prototype.write = function(output) { var THandleIdentifier = module.exports.THandleIdentifier = function(args) { this.guid = null; this.secret = null; - this.executionVersion = null; if (args) { if (args.guid !== undefined && args.guid !== null) { this.guid = args.guid; @@ -4427,9 +4543,6 @@ var THandleIdentifier = module.exports.THandleIdentifier = function(args) { } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field secret is unset!'); } - if (args.executionVersion !== undefined && args.executionVersion !== null) { - this.executionVersion = args.executionVersion; - } } }; THandleIdentifier.prototype = {}; @@ -4457,13 +4570,6 @@ THandleIdentifier.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.I16) { - this.executionVersion = input.readI16(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -4485,11 +4591,6 @@ THandleIdentifier.prototype.write = function(output) { output.writeBinary(this.secret); output.writeFieldEnd(); } - if (this.executionVersion !== null && this.executionVersion !== undefined) { - output.writeFieldBegin('executionVersion', Thrift.Type.I16, 3329); - output.writeI16(this.executionVersion); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -4497,16 +4598,12 @@ THandleIdentifier.prototype.write = function(output) { var TSessionHandle = module.exports.TSessionHandle = function(args) { this.sessionId = null; - this.serverProtocolVersion = null; if (args) { if (args.sessionId !== undefined && args.sessionId !== null) { this.sessionId = new ttypes.THandleIdentifier(args.sessionId); } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field sessionId is unset!'); } - if (args.serverProtocolVersion !== undefined && args.serverProtocolVersion !== null) { - this.serverProtocolVersion = args.serverProtocolVersion; - } } }; TSessionHandle.prototype = {}; @@ -4528,13 +4625,9 @@ TSessionHandle.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.I32) { - this.serverProtocolVersion = input.readI32(); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -4551,11 +4644,6 @@ TSessionHandle.prototype.write = function(output) { this.sessionId.write(output); output.writeFieldEnd(); } - if (this.serverProtocolVersion !== null && this.serverProtocolVersion !== undefined) { - output.writeFieldBegin('serverProtocolVersion', Thrift.Type.I32, 3329); - output.writeI32(this.serverProtocolVersion); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -4673,7 +4761,6 @@ var TOpenSessionReq = module.exports.TOpenSessionReq = function(args) { this.connectionProperties = null; this.initialNamespace = null; this.canUseMultipleCatalogs = null; - this.sessionId = null; if (args) { if (args.client_protocol !== undefined && args.client_protocol !== null) { this.client_protocol = args.client_protocol; @@ -4702,9 +4789,6 @@ var TOpenSessionReq = module.exports.TOpenSessionReq = function(args) { if (args.canUseMultipleCatalogs !== undefined && args.canUseMultipleCatalogs !== null) { this.canUseMultipleCatalogs = args.canUseMultipleCatalogs; } - if (args.sessionId !== undefined && args.sessionId !== null) { - this.sessionId = new ttypes.THandleIdentifier(args.sessionId); - } } }; TOpenSessionReq.prototype = {}; @@ -4810,14 +4894,6 @@ TOpenSessionReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.sessionId = new ttypes.THandleIdentifier(); - this.sessionId.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -4897,11 +4973,6 @@ TOpenSessionReq.prototype.write = function(output) { output.writeBool(this.canUseMultipleCatalogs); output.writeFieldEnd(); } - if (this.sessionId !== null && this.sessionId !== undefined) { - output.writeFieldBegin('sessionId', Thrift.Type.STRUCT, 3329); - this.sessionId.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -5327,7 +5398,6 @@ TGetInfoValue.prototype.write = function(output) { var TGetInfoReq = module.exports.TGetInfoReq = function(args) { this.sessionHandle = null; this.infoType = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -5339,9 +5409,6 @@ var TGetInfoReq = module.exports.TGetInfoReq = function(args) { } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field infoType is unset!'); } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetInfoReq.prototype = {}; @@ -5370,14 +5437,6 @@ TGetInfoReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -5399,11 +5458,6 @@ TGetInfoReq.prototype.write = function(output) { output.writeI32(this.infoType); output.writeFieldEnd(); } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3329); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -5769,27 +5823,6 @@ var TExecuteStatementReq = module.exports.TExecuteStatementReq = function(args) this.parameters = null; this.maxBytesPerBatch = null; this.statementConf = null; - this.operationId = null; - this.sessionConf = null; - this.rejectHighCostQueries = null; - this.estimatedCost = null; - this.executionVersion = null; - this.requestValidation = null; - this.resultPersistenceMode = null; - this.trimArrowBatchesToLimit = null; - this.fetchDisposition = null; - this.enforceResultPersistenceMode = null; - this.statementList = null; - this.persistResultManifest = null; - this.resultRetentionSeconds = null; - this.resultByteLimit = null; - this.resultDataFormat = null; - this.originatingClientIdentity = null; - this.preferSingleFileResult = null; - this.preferDriverOnlyUpload = null; - this.enforceEmbeddedSchemaCorrectness = false; - this.idempotencyToken = null; - this.throwErrorOnByteLimitTruncation = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -5840,69 +5873,6 @@ var TExecuteStatementReq = module.exports.TExecuteStatementReq = function(args) if (args.statementConf !== undefined && args.statementConf !== null) { this.statementConf = new ttypes.TStatementConf(args.statementConf); } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } - if (args.rejectHighCostQueries !== undefined && args.rejectHighCostQueries !== null) { - this.rejectHighCostQueries = args.rejectHighCostQueries; - } - if (args.estimatedCost !== undefined && args.estimatedCost !== null) { - this.estimatedCost = args.estimatedCost; - } - if (args.executionVersion !== undefined && args.executionVersion !== null) { - this.executionVersion = args.executionVersion; - } - if (args.requestValidation !== undefined && args.requestValidation !== null) { - this.requestValidation = args.requestValidation; - } - if (args.resultPersistenceMode !== undefined && args.resultPersistenceMode !== null) { - this.resultPersistenceMode = args.resultPersistenceMode; - } - if (args.trimArrowBatchesToLimit !== undefined && args.trimArrowBatchesToLimit !== null) { - this.trimArrowBatchesToLimit = args.trimArrowBatchesToLimit; - } - if (args.fetchDisposition !== undefined && args.fetchDisposition !== null) { - this.fetchDisposition = args.fetchDisposition; - } - if (args.enforceResultPersistenceMode !== undefined && args.enforceResultPersistenceMode !== null) { - this.enforceResultPersistenceMode = args.enforceResultPersistenceMode; - } - if (args.statementList !== undefined && args.statementList !== null) { - this.statementList = Thrift.copyList(args.statementList, [null]); - } - if (args.persistResultManifest !== undefined && args.persistResultManifest !== null) { - this.persistResultManifest = args.persistResultManifest; - } - if (args.resultRetentionSeconds !== undefined && args.resultRetentionSeconds !== null) { - this.resultRetentionSeconds = args.resultRetentionSeconds; - } - if (args.resultByteLimit !== undefined && args.resultByteLimit !== null) { - this.resultByteLimit = args.resultByteLimit; - } - if (args.resultDataFormat !== undefined && args.resultDataFormat !== null) { - this.resultDataFormat = new ttypes.TDBSqlResultFormat(args.resultDataFormat); - } - if (args.originatingClientIdentity !== undefined && args.originatingClientIdentity !== null) { - this.originatingClientIdentity = args.originatingClientIdentity; - } - if (args.preferSingleFileResult !== undefined && args.preferSingleFileResult !== null) { - this.preferSingleFileResult = args.preferSingleFileResult; - } - if (args.preferDriverOnlyUpload !== undefined && args.preferDriverOnlyUpload !== null) { - this.preferDriverOnlyUpload = args.preferDriverOnlyUpload; - } - if (args.enforceEmbeddedSchemaCorrectness !== undefined && args.enforceEmbeddedSchemaCorrectness !== null) { - this.enforceEmbeddedSchemaCorrectness = args.enforceEmbeddedSchemaCorrectness; - } - if (args.idempotencyToken !== undefined && args.idempotencyToken !== null) { - this.idempotencyToken = args.idempotencyToken; - } - if (args.throwErrorOnByteLimitTruncation !== undefined && args.throwErrorOnByteLimitTruncation !== null) { - this.throwErrorOnByteLimitTruncation = args.throwErrorOnByteLimitTruncation; - } } }; TExecuteStatementReq.prototype = {}; @@ -6044,194 +6014,35 @@ TExecuteStatementReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; - case 3331: - if (ftype == Thrift.Type.BOOL) { - this.rejectHighCostQueries = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3332: - if (ftype == Thrift.Type.DOUBLE) { - this.estimatedCost = input.readDouble(); - } else { - input.skip(ftype); - } - break; - case 3333: - if (ftype == Thrift.Type.I16) { - this.executionVersion = input.readI16(); - } else { + default: input.skip(ftype); - } - break; - case 3334: - if (ftype == Thrift.Type.STRING) { - this.requestValidation = input.readBinary(); - } else { - input.skip(ftype); - } - break; - case 3335: - if (ftype == Thrift.Type.I32) { - this.resultPersistenceMode = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3336: - if (ftype == Thrift.Type.BOOL) { - this.trimArrowBatchesToLimit = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3337: - if (ftype == Thrift.Type.I32) { - this.fetchDisposition = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3344: - if (ftype == Thrift.Type.BOOL) { - this.enforceResultPersistenceMode = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3345: - if (ftype == Thrift.Type.LIST) { - this.statementList = []; - var _rtmp3192 = input.readListBegin(); - var _size191 = _rtmp3192.size || 0; - for (var _i193 = 0; _i193 < _size191; ++_i193) { - var elem194 = null; - elem194 = new ttypes.TDBSqlStatement(); - elem194.read(input); - this.statementList.push(elem194); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; - case 3346: - if (ftype == Thrift.Type.BOOL) { - this.persistResultManifest = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3347: - if (ftype == Thrift.Type.I64) { - this.resultRetentionSeconds = input.readI64(); - } else { - input.skip(ftype); - } - break; - case 3348: - if (ftype == Thrift.Type.I64) { - this.resultByteLimit = input.readI64(); - } else { - input.skip(ftype); - } - break; - case 3349: - if (ftype == Thrift.Type.STRUCT) { - this.resultDataFormat = new ttypes.TDBSqlResultFormat(); - this.resultDataFormat.read(input); - } else { - input.skip(ftype); - } - break; - case 3350: - if (ftype == Thrift.Type.STRING) { - this.originatingClientIdentity = input.readString(); - } else { - input.skip(ftype); - } - break; - case 3351: - if (ftype == Thrift.Type.BOOL) { - this.preferSingleFileResult = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3352: - if (ftype == Thrift.Type.BOOL) { - this.preferDriverOnlyUpload = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3353: - if (ftype == Thrift.Type.BOOL) { - this.enforceEmbeddedSchemaCorrectness = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3360: - if (ftype == Thrift.Type.STRING) { - this.idempotencyToken = input.readString(); - } else { - input.skip(ftype); - } - break; - case 3361: - if (ftype == Thrift.Type.BOOL) { - this.throwErrorOnByteLimitTruncation = input.readBool(); - } else { - input.skip(ftype); - } - break; - default: - input.skip(ftype); - } - input.readFieldEnd(); - } - input.readStructEnd(); - return; -}; - -TExecuteStatementReq.prototype.write = function(output) { - output.writeStructBegin('TExecuteStatementReq'); - if (this.sessionHandle !== null && this.sessionHandle !== undefined) { - output.writeFieldBegin('sessionHandle', Thrift.Type.STRUCT, 1); - this.sessionHandle.write(output); - output.writeFieldEnd(); - } - if (this.statement !== null && this.statement !== undefined) { - output.writeFieldBegin('statement', Thrift.Type.STRING, 2); - output.writeString(this.statement); - output.writeFieldEnd(); - } - if (this.confOverlay !== null && this.confOverlay !== undefined) { - output.writeFieldBegin('confOverlay', Thrift.Type.MAP, 3); - output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.confOverlay)); - for (var kiter195 in this.confOverlay) { - if (this.confOverlay.hasOwnProperty(kiter195)) { - var viter196 = this.confOverlay[kiter195]; - output.writeString(kiter195); - output.writeString(viter196); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +TExecuteStatementReq.prototype.write = function(output) { + output.writeStructBegin('TExecuteStatementReq'); + if (this.sessionHandle !== null && this.sessionHandle !== undefined) { + output.writeFieldBegin('sessionHandle', Thrift.Type.STRUCT, 1); + this.sessionHandle.write(output); + output.writeFieldEnd(); + } + if (this.statement !== null && this.statement !== undefined) { + output.writeFieldBegin('statement', Thrift.Type.STRING, 2); + output.writeString(this.statement); + output.writeFieldEnd(); + } + if (this.confOverlay !== null && this.confOverlay !== undefined) { + output.writeFieldBegin('confOverlay', Thrift.Type.MAP, 3); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.confOverlay)); + for (var kiter191 in this.confOverlay) { + if (this.confOverlay.hasOwnProperty(kiter191)) { + var viter192 = this.confOverlay[kiter191]; + output.writeString(kiter191); + output.writeString(viter192); } } output.writeMapEnd(); @@ -6285,10 +6096,10 @@ TExecuteStatementReq.prototype.write = function(output) { if (this.parameters !== null && this.parameters !== undefined) { output.writeFieldBegin('parameters', Thrift.Type.LIST, 1288); output.writeListBegin(Thrift.Type.STRUCT, this.parameters.length); - for (var iter197 in this.parameters) { - if (this.parameters.hasOwnProperty(iter197)) { - iter197 = this.parameters[iter197]; - iter197.write(output); + for (var iter193 in this.parameters) { + if (this.parameters.hasOwnProperty(iter193)) { + iter193 = this.parameters[iter193]; + iter193.write(output); } } output.writeListEnd(); @@ -6304,118 +6115,6 @@ TExecuteStatementReq.prototype.write = function(output) { this.statementConf.write(output); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } - if (this.rejectHighCostQueries !== null && this.rejectHighCostQueries !== undefined) { - output.writeFieldBegin('rejectHighCostQueries', Thrift.Type.BOOL, 3331); - output.writeBool(this.rejectHighCostQueries); - output.writeFieldEnd(); - } - if (this.estimatedCost !== null && this.estimatedCost !== undefined) { - output.writeFieldBegin('estimatedCost', Thrift.Type.DOUBLE, 3332); - output.writeDouble(this.estimatedCost); - output.writeFieldEnd(); - } - if (this.executionVersion !== null && this.executionVersion !== undefined) { - output.writeFieldBegin('executionVersion', Thrift.Type.I16, 3333); - output.writeI16(this.executionVersion); - output.writeFieldEnd(); - } - if (this.requestValidation !== null && this.requestValidation !== undefined) { - output.writeFieldBegin('requestValidation', Thrift.Type.STRING, 3334); - output.writeBinary(this.requestValidation); - output.writeFieldEnd(); - } - if (this.resultPersistenceMode !== null && this.resultPersistenceMode !== undefined) { - output.writeFieldBegin('resultPersistenceMode', Thrift.Type.I32, 3335); - output.writeI32(this.resultPersistenceMode); - output.writeFieldEnd(); - } - if (this.trimArrowBatchesToLimit !== null && this.trimArrowBatchesToLimit !== undefined) { - output.writeFieldBegin('trimArrowBatchesToLimit', Thrift.Type.BOOL, 3336); - output.writeBool(this.trimArrowBatchesToLimit); - output.writeFieldEnd(); - } - if (this.fetchDisposition !== null && this.fetchDisposition !== undefined) { - output.writeFieldBegin('fetchDisposition', Thrift.Type.I32, 3337); - output.writeI32(this.fetchDisposition); - output.writeFieldEnd(); - } - if (this.enforceResultPersistenceMode !== null && this.enforceResultPersistenceMode !== undefined) { - output.writeFieldBegin('enforceResultPersistenceMode', Thrift.Type.BOOL, 3344); - output.writeBool(this.enforceResultPersistenceMode); - output.writeFieldEnd(); - } - if (this.statementList !== null && this.statementList !== undefined) { - output.writeFieldBegin('statementList', Thrift.Type.LIST, 3345); - output.writeListBegin(Thrift.Type.STRUCT, this.statementList.length); - for (var iter198 in this.statementList) { - if (this.statementList.hasOwnProperty(iter198)) { - iter198 = this.statementList[iter198]; - iter198.write(output); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } - if (this.persistResultManifest !== null && this.persistResultManifest !== undefined) { - output.writeFieldBegin('persistResultManifest', Thrift.Type.BOOL, 3346); - output.writeBool(this.persistResultManifest); - output.writeFieldEnd(); - } - if (this.resultRetentionSeconds !== null && this.resultRetentionSeconds !== undefined) { - output.writeFieldBegin('resultRetentionSeconds', Thrift.Type.I64, 3347); - output.writeI64(this.resultRetentionSeconds); - output.writeFieldEnd(); - } - if (this.resultByteLimit !== null && this.resultByteLimit !== undefined) { - output.writeFieldBegin('resultByteLimit', Thrift.Type.I64, 3348); - output.writeI64(this.resultByteLimit); - output.writeFieldEnd(); - } - if (this.resultDataFormat !== null && this.resultDataFormat !== undefined) { - output.writeFieldBegin('resultDataFormat', Thrift.Type.STRUCT, 3349); - this.resultDataFormat.write(output); - output.writeFieldEnd(); - } - if (this.originatingClientIdentity !== null && this.originatingClientIdentity !== undefined) { - output.writeFieldBegin('originatingClientIdentity', Thrift.Type.STRING, 3350); - output.writeString(this.originatingClientIdentity); - output.writeFieldEnd(); - } - if (this.preferSingleFileResult !== null && this.preferSingleFileResult !== undefined) { - output.writeFieldBegin('preferSingleFileResult', Thrift.Type.BOOL, 3351); - output.writeBool(this.preferSingleFileResult); - output.writeFieldEnd(); - } - if (this.preferDriverOnlyUpload !== null && this.preferDriverOnlyUpload !== undefined) { - output.writeFieldBegin('preferDriverOnlyUpload', Thrift.Type.BOOL, 3352); - output.writeBool(this.preferDriverOnlyUpload); - output.writeFieldEnd(); - } - if (this.enforceEmbeddedSchemaCorrectness !== null && this.enforceEmbeddedSchemaCorrectness !== undefined) { - output.writeFieldBegin('enforceEmbeddedSchemaCorrectness', Thrift.Type.BOOL, 3353); - output.writeBool(this.enforceEmbeddedSchemaCorrectness); - output.writeFieldEnd(); - } - if (this.idempotencyToken !== null && this.idempotencyToken !== undefined) { - output.writeFieldBegin('idempotencyToken', Thrift.Type.STRING, 3360); - output.writeString(this.idempotencyToken); - output.writeFieldEnd(); - } - if (this.throwErrorOnByteLimitTruncation !== null && this.throwErrorOnByteLimitTruncation !== undefined) { - output.writeFieldBegin('throwErrorOnByteLimitTruncation', Thrift.Type.BOOL, 3361); - output.writeBool(this.throwErrorOnByteLimitTruncation); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -6550,11 +6249,107 @@ TSparkParameterValue.prototype.write = function(output) { return; }; +var TSparkParameterValueArg = module.exports.TSparkParameterValueArg = function(args) { + this.type = null; + this.value = null; + this.arguments = null; + if (args) { + if (args.type !== undefined && args.type !== null) { + this.type = args.type; + } + if (args.value !== undefined && args.value !== null) { + this.value = args.value; + } + if (args.arguments !== undefined && args.arguments !== null) { + this.arguments = Thrift.copyList(args.arguments, [null]); + } + } +}; +TSparkParameterValueArg.prototype = {}; +TSparkParameterValueArg.prototype.read = function(input) { + input.readStructBegin(); + while (true) { + var ret = input.readFieldBegin(); + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) { + case 1: + if (ftype == Thrift.Type.STRING) { + this.type = input.readString(); + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRING) { + this.value = input.readString(); + } else { + input.skip(ftype); + } + break; + case 3: + if (ftype == Thrift.Type.LIST) { + this.arguments = []; + var _rtmp3195 = input.readListBegin(); + var _size194 = _rtmp3195.size || 0; + for (var _i196 = 0; _i196 < _size194; ++_i196) { + var elem197 = null; + elem197 = new ttypes.TSparkParameterValueArg(); + elem197.read(input); + this.arguments.push(elem197); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +TSparkParameterValueArg.prototype.write = function(output) { + output.writeStructBegin('TSparkParameterValueArg'); + if (this.type !== null && this.type !== undefined) { + output.writeFieldBegin('type', Thrift.Type.STRING, 1); + output.writeString(this.type); + output.writeFieldEnd(); + } + if (this.value !== null && this.value !== undefined) { + output.writeFieldBegin('value', Thrift.Type.STRING, 2); + output.writeString(this.value); + output.writeFieldEnd(); + } + if (this.arguments !== null && this.arguments !== undefined) { + output.writeFieldBegin('arguments', Thrift.Type.LIST, 3); + output.writeListBegin(Thrift.Type.STRUCT, this.arguments.length); + for (var iter198 in this.arguments) { + if (this.arguments.hasOwnProperty(iter198)) { + iter198 = this.arguments[iter198]; + iter198.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + var TSparkParameter = module.exports.TSparkParameter = function(args) { this.ordinal = null; this.name = null; this.type = null; this.value = null; + this.arguments = null; if (args) { if (args.ordinal !== undefined && args.ordinal !== null) { this.ordinal = args.ordinal; @@ -6568,6 +6363,9 @@ var TSparkParameter = module.exports.TSparkParameter = function(args) { if (args.value !== undefined && args.value !== null) { this.value = new ttypes.TSparkParameterValue(args.value); } + if (args.arguments !== undefined && args.arguments !== null) { + this.arguments = Thrift.copyList(args.arguments, [ttypes.TSparkParameterValueArg]); + } } }; TSparkParameter.prototype = {}; @@ -6610,6 +6408,22 @@ TSparkParameter.prototype.read = function(input) { input.skip(ftype); } break; + case 5: + if (ftype == Thrift.Type.LIST) { + this.arguments = []; + var _rtmp3200 = input.readListBegin(); + var _size199 = _rtmp3200.size || 0; + for (var _i201 = 0; _i201 < _size199; ++_i201) { + var elem202 = null; + elem202 = new ttypes.TSparkParameterValueArg(); + elem202.read(input); + this.arguments.push(elem202); + } + input.readListEnd(); + } else { + input.skip(ftype); + } + break; default: input.skip(ftype); } @@ -6641,6 +6455,18 @@ TSparkParameter.prototype.write = function(output) { this.value.write(output); output.writeFieldEnd(); } + if (this.arguments !== null && this.arguments !== undefined) { + output.writeFieldBegin('arguments', Thrift.Type.LIST, 5); + output.writeListBegin(Thrift.Type.STRUCT, this.arguments.length); + for (var iter203 in this.arguments) { + if (this.arguments.hasOwnProperty(iter203)) { + iter203 = this.arguments[iter203]; + iter203.write(output); + } + } + output.writeListEnd(); + output.writeFieldEnd(); + } output.writeFieldStop(); output.writeStructEnd(); return; @@ -6746,15 +6572,6 @@ var TExecuteStatementResp = module.exports.TExecuteStatementResp = function(args this.status = null; this.operationHandle = null; this.directResults = null; - this.executionRejected = null; - this.maxClusterCapacity = null; - this.queryCost = null; - this.sessionConf = null; - this.currentClusterLoad = null; - this.idempotencyType = null; - this.remoteResultCacheEnabled = null; - this.isServerless = null; - this.operationHandles = null; if (args) { if (args.status !== undefined && args.status !== null) { this.status = new ttypes.TStatus(args.status); @@ -6767,33 +6584,6 @@ var TExecuteStatementResp = module.exports.TExecuteStatementResp = function(args if (args.directResults !== undefined && args.directResults !== null) { this.directResults = new ttypes.TSparkDirectResults(args.directResults); } - if (args.executionRejected !== undefined && args.executionRejected !== null) { - this.executionRejected = args.executionRejected; - } - if (args.maxClusterCapacity !== undefined && args.maxClusterCapacity !== null) { - this.maxClusterCapacity = args.maxClusterCapacity; - } - if (args.queryCost !== undefined && args.queryCost !== null) { - this.queryCost = args.queryCost; - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } - if (args.currentClusterLoad !== undefined && args.currentClusterLoad !== null) { - this.currentClusterLoad = args.currentClusterLoad; - } - if (args.idempotencyType !== undefined && args.idempotencyType !== null) { - this.idempotencyType = args.idempotencyType; - } - if (args.remoteResultCacheEnabled !== undefined && args.remoteResultCacheEnabled !== null) { - this.remoteResultCacheEnabled = args.remoteResultCacheEnabled; - } - if (args.isServerless !== undefined && args.isServerless !== null) { - this.isServerless = args.isServerless; - } - if (args.operationHandles !== undefined && args.operationHandles !== null) { - this.operationHandles = Thrift.copyList(args.operationHandles, [ttypes.TOperationHandle]); - } } }; TExecuteStatementResp.prototype = {}; @@ -6831,79 +6621,6 @@ TExecuteStatementResp.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.BOOL) { - this.executionRejected = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.DOUBLE) { - this.maxClusterCapacity = input.readDouble(); - } else { - input.skip(ftype); - } - break; - case 3331: - if (ftype == Thrift.Type.DOUBLE) { - this.queryCost = input.readDouble(); - } else { - input.skip(ftype); - } - break; - case 3332: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; - case 3333: - if (ftype == Thrift.Type.DOUBLE) { - this.currentClusterLoad = input.readDouble(); - } else { - input.skip(ftype); - } - break; - case 3334: - if (ftype == Thrift.Type.I32) { - this.idempotencyType = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3335: - if (ftype == Thrift.Type.BOOL) { - this.remoteResultCacheEnabled = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3336: - if (ftype == Thrift.Type.BOOL) { - this.isServerless = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3337: - if (ftype == Thrift.Type.LIST) { - this.operationHandles = []; - var _rtmp3200 = input.readListBegin(); - var _size199 = _rtmp3200.size || 0; - for (var _i201 = 0; _i201 < _size199; ++_i201) { - var elem202 = null; - elem202 = new ttypes.TOperationHandle(); - elem202.read(input); - this.operationHandles.push(elem202); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -6930,58 +6647,6 @@ TExecuteStatementResp.prototype.write = function(output) { this.directResults.write(output); output.writeFieldEnd(); } - if (this.executionRejected !== null && this.executionRejected !== undefined) { - output.writeFieldBegin('executionRejected', Thrift.Type.BOOL, 3329); - output.writeBool(this.executionRejected); - output.writeFieldEnd(); - } - if (this.maxClusterCapacity !== null && this.maxClusterCapacity !== undefined) { - output.writeFieldBegin('maxClusterCapacity', Thrift.Type.DOUBLE, 3330); - output.writeDouble(this.maxClusterCapacity); - output.writeFieldEnd(); - } - if (this.queryCost !== null && this.queryCost !== undefined) { - output.writeFieldBegin('queryCost', Thrift.Type.DOUBLE, 3331); - output.writeDouble(this.queryCost); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3332); - this.sessionConf.write(output); - output.writeFieldEnd(); - } - if (this.currentClusterLoad !== null && this.currentClusterLoad !== undefined) { - output.writeFieldBegin('currentClusterLoad', Thrift.Type.DOUBLE, 3333); - output.writeDouble(this.currentClusterLoad); - output.writeFieldEnd(); - } - if (this.idempotencyType !== null && this.idempotencyType !== undefined) { - output.writeFieldBegin('idempotencyType', Thrift.Type.I32, 3334); - output.writeI32(this.idempotencyType); - output.writeFieldEnd(); - } - if (this.remoteResultCacheEnabled !== null && this.remoteResultCacheEnabled !== undefined) { - output.writeFieldBegin('remoteResultCacheEnabled', Thrift.Type.BOOL, 3335); - output.writeBool(this.remoteResultCacheEnabled); - output.writeFieldEnd(); - } - if (this.isServerless !== null && this.isServerless !== undefined) { - output.writeFieldBegin('isServerless', Thrift.Type.BOOL, 3336); - output.writeBool(this.isServerless); - output.writeFieldEnd(); - } - if (this.operationHandles !== null && this.operationHandles !== undefined) { - output.writeFieldBegin('operationHandles', Thrift.Type.LIST, 3337); - output.writeListBegin(Thrift.Type.STRUCT, this.operationHandles.length); - for (var iter203 in this.operationHandles) { - if (this.operationHandles.hasOwnProperty(iter203)) { - iter203 = this.operationHandles[iter203]; - iter203.write(output); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -6991,8 +6656,6 @@ var TGetTypeInfoReq = module.exports.TGetTypeInfoReq = function(args) { this.sessionHandle = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -7005,12 +6668,6 @@ var TGetTypeInfoReq = module.exports.TGetTypeInfoReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetTypeInfoReq.prototype = {}; @@ -7047,22 +6704,6 @@ TGetTypeInfoReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -7089,16 +6730,6 @@ TGetTypeInfoReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -7192,8 +6823,6 @@ var TGetCatalogsReq = module.exports.TGetCatalogsReq = function(args) { this.sessionHandle = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -7206,12 +6835,6 @@ var TGetCatalogsReq = module.exports.TGetCatalogsReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetCatalogsReq.prototype = {}; @@ -7248,22 +6871,6 @@ TGetCatalogsReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -7290,16 +6897,6 @@ TGetCatalogsReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -7395,8 +6992,6 @@ var TGetSchemasReq = module.exports.TGetSchemasReq = function(args) { this.schemaName = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -7415,12 +7010,6 @@ var TGetSchemasReq = module.exports.TGetSchemasReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetSchemasReq.prototype = {}; @@ -7471,22 +7060,6 @@ TGetSchemasReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -7523,16 +7096,6 @@ TGetSchemasReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -7630,8 +7193,6 @@ var TGetTablesReq = module.exports.TGetTablesReq = function(args) { this.tableTypes = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -7656,12 +7217,6 @@ var TGetTablesReq = module.exports.TGetTablesReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetTablesReq.prototype = {}; @@ -7734,22 +7289,6 @@ TGetTablesReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -7803,16 +7342,6 @@ TGetTablesReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -7906,8 +7435,6 @@ var TGetTableTypesReq = module.exports.TGetTableTypesReq = function(args) { this.sessionHandle = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -7920,12 +7447,6 @@ var TGetTableTypesReq = module.exports.TGetTableTypesReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetTableTypesReq.prototype = {}; @@ -7962,22 +7483,6 @@ TGetTableTypesReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -8004,16 +7509,6 @@ TGetTableTypesReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -8111,8 +7606,6 @@ var TGetColumnsReq = module.exports.TGetColumnsReq = function(args) { this.columnName = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -8137,12 +7630,6 @@ var TGetColumnsReq = module.exports.TGetColumnsReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetColumnsReq.prototype = {}; @@ -8207,22 +7694,6 @@ TGetColumnsReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -8269,16 +7740,6 @@ TGetColumnsReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -8375,8 +7836,6 @@ var TGetFunctionsReq = module.exports.TGetFunctionsReq = function(args) { this.functionName = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -8400,12 +7859,6 @@ var TGetFunctionsReq = module.exports.TGetFunctionsReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetFunctionsReq.prototype = {}; @@ -8463,22 +7916,6 @@ TGetFunctionsReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -8516,18 +7953,8 @@ TGetFunctionsReq.prototype.write = function(output) { output.writeFieldEnd(); } if (this.runAsync !== null && this.runAsync !== undefined) { - output.writeFieldBegin('runAsync', Thrift.Type.BOOL, 1282); - output.writeBool(this.runAsync); - output.writeFieldEnd(); - } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); + output.writeFieldBegin('runAsync', Thrift.Type.BOOL, 1282); + output.writeBool(this.runAsync); output.writeFieldEnd(); } output.writeFieldStop(); @@ -8626,8 +8053,6 @@ var TGetPrimaryKeysReq = module.exports.TGetPrimaryKeysReq = function(args) { this.tableName = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -8649,12 +8074,6 @@ var TGetPrimaryKeysReq = module.exports.TGetPrimaryKeysReq = function(args) { if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetPrimaryKeysReq.prototype = {}; @@ -8712,22 +8131,6 @@ TGetPrimaryKeysReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -8769,16 +8172,6 @@ TGetPrimaryKeysReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -8878,8 +8271,6 @@ var TGetCrossReferenceReq = module.exports.TGetCrossReferenceReq = function(args this.foreignTableName = null; this.getDirectResults = null; this.runAsync = false; - this.operationId = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -8910,12 +8301,6 @@ var TGetCrossReferenceReq = module.exports.TGetCrossReferenceReq = function(args if (args.runAsync !== undefined && args.runAsync !== null) { this.runAsync = args.runAsync; } - if (args.operationId !== undefined && args.operationId !== null) { - this.operationId = new ttypes.THandleIdentifier(args.operationId); - } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetCrossReferenceReq.prototype = {}; @@ -8994,22 +8379,6 @@ TGetCrossReferenceReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.operationId = new ttypes.THandleIdentifier(); - this.operationId.read(input); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -9066,16 +8435,6 @@ TGetCrossReferenceReq.prototype.write = function(output) { output.writeBool(this.runAsync); output.writeFieldEnd(); } - if (this.operationId !== null && this.operationId !== undefined) { - output.writeFieldBegin('operationId', Thrift.Type.STRUCT, 3329); - this.operationId.write(output); - output.writeFieldEnd(); - } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3330); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -9246,10 +8605,6 @@ var TGetOperationStatusResp = module.exports.TGetOperationStatusResp = function( this.displayMessage = null; this.diagnosticInfo = null; this.errorDetailsJson = null; - this.responseValidation = null; - this.idempotencyType = null; - this.statementTimeout = null; - this.statementTimeoutLevel = null; if (args) { if (args.status !== undefined && args.status !== null) { this.status = new ttypes.TStatus(args.status); @@ -9295,18 +8650,6 @@ var TGetOperationStatusResp = module.exports.TGetOperationStatusResp = function( if (args.errorDetailsJson !== undefined && args.errorDetailsJson !== null) { this.errorDetailsJson = args.errorDetailsJson; } - if (args.responseValidation !== undefined && args.responseValidation !== null) { - this.responseValidation = args.responseValidation; - } - if (args.idempotencyType !== undefined && args.idempotencyType !== null) { - this.idempotencyType = args.idempotencyType; - } - if (args.statementTimeout !== undefined && args.statementTimeout !== null) { - this.statementTimeout = args.statementTimeout; - } - if (args.statementTimeoutLevel !== undefined && args.statementTimeoutLevel !== null) { - this.statementTimeoutLevel = args.statementTimeoutLevel; - } } }; TGetOperationStatusResp.prototype = {}; @@ -9420,34 +8763,6 @@ TGetOperationStatusResp.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRING) { - this.responseValidation = input.readBinary(); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.I32) { - this.idempotencyType = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3331: - if (ftype == Thrift.Type.I64) { - this.statementTimeout = input.readI64(); - } else { - input.skip(ftype); - } - break; - case 3332: - if (ftype == Thrift.Type.I32) { - this.statementTimeoutLevel = input.readI32(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -9529,26 +8844,6 @@ TGetOperationStatusResp.prototype.write = function(output) { output.writeString(this.errorDetailsJson); output.writeFieldEnd(); } - if (this.responseValidation !== null && this.responseValidation !== undefined) { - output.writeFieldBegin('responseValidation', Thrift.Type.STRING, 3329); - output.writeBinary(this.responseValidation); - output.writeFieldEnd(); - } - if (this.idempotencyType !== null && this.idempotencyType !== undefined) { - output.writeFieldBegin('idempotencyType', Thrift.Type.I32, 3330); - output.writeI32(this.idempotencyType); - output.writeFieldEnd(); - } - if (this.statementTimeout !== null && this.statementTimeout !== undefined) { - output.writeFieldBegin('statementTimeout', Thrift.Type.I64, 3331); - output.writeI64(this.statementTimeout); - output.writeFieldEnd(); - } - if (this.statementTimeoutLevel !== null && this.statementTimeoutLevel !== undefined) { - output.writeFieldBegin('statementTimeoutLevel', Thrift.Type.I32, 3332); - output.writeI32(this.statementTimeoutLevel); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -9556,20 +8851,12 @@ TGetOperationStatusResp.prototype.write = function(output) { var TCancelOperationReq = module.exports.TCancelOperationReq = function(args) { this.operationHandle = null; - this.executionVersion = null; - this.replacedByNextAttempt = null; if (args) { if (args.operationHandle !== undefined && args.operationHandle !== null) { this.operationHandle = new ttypes.TOperationHandle(args.operationHandle); } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field operationHandle is unset!'); } - if (args.executionVersion !== undefined && args.executionVersion !== null) { - this.executionVersion = args.executionVersion; - } - if (args.replacedByNextAttempt !== undefined && args.replacedByNextAttempt !== null) { - this.replacedByNextAttempt = args.replacedByNextAttempt; - } } }; TCancelOperationReq.prototype = {}; @@ -9591,20 +8878,9 @@ TCancelOperationReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.I16) { - this.executionVersion = input.readI16(); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.BOOL) { - this.replacedByNextAttempt = input.readBool(); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -9621,16 +8897,6 @@ TCancelOperationReq.prototype.write = function(output) { this.operationHandle.write(output); output.writeFieldEnd(); } - if (this.executionVersion !== null && this.executionVersion !== undefined) { - output.writeFieldBegin('executionVersion', Thrift.Type.I16, 3329); - output.writeI16(this.executionVersion); - output.writeFieldEnd(); - } - if (this.replacedByNextAttempt !== null && this.replacedByNextAttempt !== undefined) { - output.writeFieldBegin('replacedByNextAttempt', Thrift.Type.BOOL, 3330); - output.writeBool(this.replacedByNextAttempt); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -9691,16 +8957,12 @@ TCancelOperationResp.prototype.write = function(output) { var TCloseOperationReq = module.exports.TCloseOperationReq = function(args) { this.operationHandle = null; - this.closeReason = 0; if (args) { if (args.operationHandle !== undefined && args.operationHandle !== null) { this.operationHandle = new ttypes.TOperationHandle(args.operationHandle); } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field operationHandle is unset!'); } - if (args.closeReason !== undefined && args.closeReason !== null) { - this.closeReason = args.closeReason; - } } }; TCloseOperationReq.prototype = {}; @@ -9722,13 +8984,9 @@ TCloseOperationReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.I32) { - this.closeReason = input.readI32(); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -9745,11 +9003,6 @@ TCloseOperationReq.prototype.write = function(output) { this.operationHandle.write(output); output.writeFieldEnd(); } - if (this.closeReason !== null && this.closeReason !== undefined) { - output.writeFieldBegin('closeReason', Thrift.Type.I32, 3329); - output.writeI32(this.closeReason); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -9810,16 +9063,12 @@ TCloseOperationResp.prototype.write = function(output) { var TGetResultSetMetadataReq = module.exports.TGetResultSetMetadataReq = function(args) { this.operationHandle = null; - this.includeCloudResultFiles = null; if (args) { if (args.operationHandle !== undefined && args.operationHandle !== null) { this.operationHandle = new ttypes.TOperationHandle(args.operationHandle); } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field operationHandle is unset!'); } - if (args.includeCloudResultFiles !== undefined && args.includeCloudResultFiles !== null) { - this.includeCloudResultFiles = args.includeCloudResultFiles; - } } }; TGetResultSetMetadataReq.prototype = {}; @@ -9841,13 +9090,9 @@ TGetResultSetMetadataReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.BOOL) { - this.includeCloudResultFiles = input.readBool(); - } else { + case 0: input.skip(ftype); - } - break; + break; default: input.skip(ftype); } @@ -9864,11 +9109,6 @@ TGetResultSetMetadataReq.prototype.write = function(output) { this.operationHandle.write(output); output.writeFieldEnd(); } - if (this.includeCloudResultFiles !== null && this.includeCloudResultFiles !== undefined) { - output.writeFieldBegin('includeCloudResultFiles', Thrift.Type.BOOL, 3329); - output.writeBool(this.includeCloudResultFiles); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -9884,18 +9124,6 @@ var TGetResultSetMetadataResp = module.exports.TGetResultSetMetadataResp = funct this.uncompressedBytes = null; this.compressedBytes = null; this.isStagingOperation = null; - this.reasonForNoCloudFetch = null; - this.resultFiles = null; - this.manifestFile = null; - this.manifestFileFormat = null; - this.cacheLookupLatency = null; - this.remoteCacheMissReason = null; - this.fetchDisposition = null; - this.remoteResultCacheEnabled = null; - this.isServerless = null; - this.resultDataFormat = null; - this.truncatedByThriftLimit = null; - this.resultByteLimit = null; if (args) { if (args.status !== undefined && args.status !== null) { this.status = new ttypes.TStatus(args.status); @@ -9926,42 +9154,6 @@ var TGetResultSetMetadataResp = module.exports.TGetResultSetMetadataResp = funct if (args.isStagingOperation !== undefined && args.isStagingOperation !== null) { this.isStagingOperation = args.isStagingOperation; } - if (args.reasonForNoCloudFetch !== undefined && args.reasonForNoCloudFetch !== null) { - this.reasonForNoCloudFetch = args.reasonForNoCloudFetch; - } - if (args.resultFiles !== undefined && args.resultFiles !== null) { - this.resultFiles = Thrift.copyList(args.resultFiles, [ttypes.TDBSqlCloudResultFile]); - } - if (args.manifestFile !== undefined && args.manifestFile !== null) { - this.manifestFile = args.manifestFile; - } - if (args.manifestFileFormat !== undefined && args.manifestFileFormat !== null) { - this.manifestFileFormat = args.manifestFileFormat; - } - if (args.cacheLookupLatency !== undefined && args.cacheLookupLatency !== null) { - this.cacheLookupLatency = args.cacheLookupLatency; - } - if (args.remoteCacheMissReason !== undefined && args.remoteCacheMissReason !== null) { - this.remoteCacheMissReason = args.remoteCacheMissReason; - } - if (args.fetchDisposition !== undefined && args.fetchDisposition !== null) { - this.fetchDisposition = args.fetchDisposition; - } - if (args.remoteResultCacheEnabled !== undefined && args.remoteResultCacheEnabled !== null) { - this.remoteResultCacheEnabled = args.remoteResultCacheEnabled; - } - if (args.isServerless !== undefined && args.isServerless !== null) { - this.isServerless = args.isServerless; - } - if (args.resultDataFormat !== undefined && args.resultDataFormat !== null) { - this.resultDataFormat = new ttypes.TDBSqlResultFormat(args.resultDataFormat); - } - if (args.truncatedByThriftLimit !== undefined && args.truncatedByThriftLimit !== null) { - this.truncatedByThriftLimit = args.truncatedByThriftLimit; - } - if (args.resultByteLimit !== undefined && args.resultByteLimit !== null) { - this.resultByteLimit = args.resultByteLimit; - } } }; TGetResultSetMetadataResp.prototype = {}; @@ -10040,100 +9232,6 @@ TGetResultSetMetadataResp.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.I32) { - this.reasonForNoCloudFetch = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3330: - if (ftype == Thrift.Type.LIST) { - this.resultFiles = []; - var _rtmp3210 = input.readListBegin(); - var _size209 = _rtmp3210.size || 0; - for (var _i211 = 0; _i211 < _size209; ++_i211) { - var elem212 = null; - elem212 = new ttypes.TDBSqlCloudResultFile(); - elem212.read(input); - this.resultFiles.push(elem212); - } - input.readListEnd(); - } else { - input.skip(ftype); - } - break; - case 3331: - if (ftype == Thrift.Type.STRING) { - this.manifestFile = input.readString(); - } else { - input.skip(ftype); - } - break; - case 3332: - if (ftype == Thrift.Type.I32) { - this.manifestFileFormat = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3333: - if (ftype == Thrift.Type.I64) { - this.cacheLookupLatency = input.readI64(); - } else { - input.skip(ftype); - } - break; - case 3334: - if (ftype == Thrift.Type.STRING) { - this.remoteCacheMissReason = input.readString(); - } else { - input.skip(ftype); - } - break; - case 3335: - if (ftype == Thrift.Type.I32) { - this.fetchDisposition = input.readI32(); - } else { - input.skip(ftype); - } - break; - case 3336: - if (ftype == Thrift.Type.BOOL) { - this.remoteResultCacheEnabled = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3337: - if (ftype == Thrift.Type.BOOL) { - this.isServerless = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3344: - if (ftype == Thrift.Type.STRUCT) { - this.resultDataFormat = new ttypes.TDBSqlResultFormat(); - this.resultDataFormat.read(input); - } else { - input.skip(ftype); - } - break; - case 3345: - if (ftype == Thrift.Type.BOOL) { - this.truncatedByThriftLimit = input.readBool(); - } else { - input.skip(ftype); - } - break; - case 3346: - if (ftype == Thrift.Type.I64) { - this.resultByteLimit = input.readI64(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -10190,73 +9288,6 @@ TGetResultSetMetadataResp.prototype.write = function(output) { output.writeBool(this.isStagingOperation); output.writeFieldEnd(); } - if (this.reasonForNoCloudFetch !== null && this.reasonForNoCloudFetch !== undefined) { - output.writeFieldBegin('reasonForNoCloudFetch', Thrift.Type.I32, 3329); - output.writeI32(this.reasonForNoCloudFetch); - output.writeFieldEnd(); - } - if (this.resultFiles !== null && this.resultFiles !== undefined) { - output.writeFieldBegin('resultFiles', Thrift.Type.LIST, 3330); - output.writeListBegin(Thrift.Type.STRUCT, this.resultFiles.length); - for (var iter213 in this.resultFiles) { - if (this.resultFiles.hasOwnProperty(iter213)) { - iter213 = this.resultFiles[iter213]; - iter213.write(output); - } - } - output.writeListEnd(); - output.writeFieldEnd(); - } - if (this.manifestFile !== null && this.manifestFile !== undefined) { - output.writeFieldBegin('manifestFile', Thrift.Type.STRING, 3331); - output.writeString(this.manifestFile); - output.writeFieldEnd(); - } - if (this.manifestFileFormat !== null && this.manifestFileFormat !== undefined) { - output.writeFieldBegin('manifestFileFormat', Thrift.Type.I32, 3332); - output.writeI32(this.manifestFileFormat); - output.writeFieldEnd(); - } - if (this.cacheLookupLatency !== null && this.cacheLookupLatency !== undefined) { - output.writeFieldBegin('cacheLookupLatency', Thrift.Type.I64, 3333); - output.writeI64(this.cacheLookupLatency); - output.writeFieldEnd(); - } - if (this.remoteCacheMissReason !== null && this.remoteCacheMissReason !== undefined) { - output.writeFieldBegin('remoteCacheMissReason', Thrift.Type.STRING, 3334); - output.writeString(this.remoteCacheMissReason); - output.writeFieldEnd(); - } - if (this.fetchDisposition !== null && this.fetchDisposition !== undefined) { - output.writeFieldBegin('fetchDisposition', Thrift.Type.I32, 3335); - output.writeI32(this.fetchDisposition); - output.writeFieldEnd(); - } - if (this.remoteResultCacheEnabled !== null && this.remoteResultCacheEnabled !== undefined) { - output.writeFieldBegin('remoteResultCacheEnabled', Thrift.Type.BOOL, 3336); - output.writeBool(this.remoteResultCacheEnabled); - output.writeFieldEnd(); - } - if (this.isServerless !== null && this.isServerless !== undefined) { - output.writeFieldBegin('isServerless', Thrift.Type.BOOL, 3337); - output.writeBool(this.isServerless); - output.writeFieldEnd(); - } - if (this.resultDataFormat !== null && this.resultDataFormat !== undefined) { - output.writeFieldBegin('resultDataFormat', Thrift.Type.STRUCT, 3344); - this.resultDataFormat.write(output); - output.writeFieldEnd(); - } - if (this.truncatedByThriftLimit !== null && this.truncatedByThriftLimit !== undefined) { - output.writeFieldBegin('truncatedByThriftLimit', Thrift.Type.BOOL, 3345); - output.writeBool(this.truncatedByThriftLimit); - output.writeFieldEnd(); - } - if (this.resultByteLimit !== null && this.resultByteLimit !== undefined) { - output.writeFieldBegin('resultByteLimit', Thrift.Type.I64, 3346); - output.writeI64(this.resultByteLimit); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -10417,7 +9448,6 @@ var TFetchResultsResp = module.exports.TFetchResultsResp = function(args) { this.hasMoreRows = null; this.results = null; this.resultSetMetadata = null; - this.responseValidation = null; if (args) { if (args.status !== undefined && args.status !== null) { this.status = new ttypes.TStatus(args.status); @@ -10433,9 +9463,6 @@ var TFetchResultsResp = module.exports.TFetchResultsResp = function(args) { if (args.resultSetMetadata !== undefined && args.resultSetMetadata !== null) { this.resultSetMetadata = new ttypes.TGetResultSetMetadataResp(args.resultSetMetadata); } - if (args.responseValidation !== undefined && args.responseValidation !== null) { - this.responseValidation = args.responseValidation; - } } }; TFetchResultsResp.prototype = {}; @@ -10480,13 +9507,6 @@ TFetchResultsResp.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRING) { - this.responseValidation = input.readBinary(); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -10518,11 +9538,6 @@ TFetchResultsResp.prototype.write = function(output) { this.resultSetMetadata.write(output); output.writeFieldEnd(); } - if (this.responseValidation !== null && this.responseValidation !== undefined) { - output.writeFieldBegin('responseValidation', Thrift.Type.STRING, 3329); - output.writeBinary(this.responseValidation); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -10532,7 +9547,6 @@ var TGetDelegationTokenReq = module.exports.TGetDelegationTokenReq = function(ar this.sessionHandle = null; this.owner = null; this.renewer = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -10549,9 +9563,6 @@ var TGetDelegationTokenReq = module.exports.TGetDelegationTokenReq = function(ar } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field renewer is unset!'); } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TGetDelegationTokenReq.prototype = {}; @@ -10587,14 +9598,6 @@ TGetDelegationTokenReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -10621,11 +9624,6 @@ TGetDelegationTokenReq.prototype.write = function(output) { output.writeString(this.renewer); output.writeFieldEnd(); } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3329); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -10700,7 +9698,6 @@ TGetDelegationTokenResp.prototype.write = function(output) { var TCancelDelegationTokenReq = module.exports.TCancelDelegationTokenReq = function(args) { this.sessionHandle = null; this.delegationToken = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -10712,9 +9709,6 @@ var TCancelDelegationTokenReq = module.exports.TCancelDelegationTokenReq = funct } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field delegationToken is unset!'); } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TCancelDelegationTokenReq.prototype = {}; @@ -10743,14 +9737,6 @@ TCancelDelegationTokenReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -10772,11 +9758,6 @@ TCancelDelegationTokenReq.prototype.write = function(output) { output.writeString(this.delegationToken); output.writeFieldEnd(); } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3329); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -10838,7 +9819,6 @@ TCancelDelegationTokenResp.prototype.write = function(output) { var TRenewDelegationTokenReq = module.exports.TRenewDelegationTokenReq = function(args) { this.sessionHandle = null; this.delegationToken = null; - this.sessionConf = null; if (args) { if (args.sessionHandle !== undefined && args.sessionHandle !== null) { this.sessionHandle = new ttypes.TSessionHandle(args.sessionHandle); @@ -10850,9 +9830,6 @@ var TRenewDelegationTokenReq = module.exports.TRenewDelegationTokenReq = functio } else { throw new Thrift.TProtocolException(Thrift.TProtocolExceptionType.UNKNOWN, 'Required field delegationToken is unset!'); } - if (args.sessionConf !== undefined && args.sessionConf !== null) { - this.sessionConf = new ttypes.TDBSqlSessionConf(args.sessionConf); - } } }; TRenewDelegationTokenReq.prototype = {}; @@ -10881,14 +9858,6 @@ TRenewDelegationTokenReq.prototype.read = function(input) { input.skip(ftype); } break; - case 3329: - if (ftype == Thrift.Type.STRUCT) { - this.sessionConf = new ttypes.TDBSqlSessionConf(); - this.sessionConf.read(input); - } else { - input.skip(ftype); - } - break; default: input.skip(ftype); } @@ -10910,11 +9879,6 @@ TRenewDelegationTokenReq.prototype.write = function(output) { output.writeString(this.delegationToken); output.writeFieldEnd(); } - if (this.sessionConf !== null && this.sessionConf !== undefined) { - output.writeFieldBegin('sessionConf', Thrift.Type.STRUCT, 3329); - this.sessionConf.write(output); - output.writeFieldEnd(); - } output.writeFieldStop(); output.writeStructEnd(); return; @@ -11027,12 +9991,12 @@ TProgressUpdateResp.prototype.read = function(input) { case 1: if (ftype == Thrift.Type.LIST) { this.headerNames = []; - var _rtmp3215 = input.readListBegin(); - var _size214 = _rtmp3215.size || 0; - for (var _i216 = 0; _i216 < _size214; ++_i216) { - var elem217 = null; - elem217 = input.readString(); - this.headerNames.push(elem217); + var _rtmp3210 = input.readListBegin(); + var _size209 = _rtmp3210.size || 0; + for (var _i211 = 0; _i211 < _size209; ++_i211) { + var elem212 = null; + elem212 = input.readString(); + this.headerNames.push(elem212); } input.readListEnd(); } else { @@ -11042,20 +10006,20 @@ TProgressUpdateResp.prototype.read = function(input) { case 2: if (ftype == Thrift.Type.LIST) { this.rows = []; - var _rtmp3219 = input.readListBegin(); - var _size218 = _rtmp3219.size || 0; - for (var _i220 = 0; _i220 < _size218; ++_i220) { - var elem221 = null; - elem221 = []; - var _rtmp3223 = input.readListBegin(); - var _size222 = _rtmp3223.size || 0; - for (var _i224 = 0; _i224 < _size222; ++_i224) { - var elem225 = null; - elem225 = input.readString(); - elem221.push(elem225); + var _rtmp3214 = input.readListBegin(); + var _size213 = _rtmp3214.size || 0; + for (var _i215 = 0; _i215 < _size213; ++_i215) { + var elem216 = null; + elem216 = []; + var _rtmp3218 = input.readListBegin(); + var _size217 = _rtmp3218.size || 0; + for (var _i219 = 0; _i219 < _size217; ++_i219) { + var elem220 = null; + elem220 = input.readString(); + elem216.push(elem220); } input.readListEnd(); - this.rows.push(elem221); + this.rows.push(elem216); } input.readListEnd(); } else { @@ -11104,10 +10068,10 @@ TProgressUpdateResp.prototype.write = function(output) { if (this.headerNames !== null && this.headerNames !== undefined) { output.writeFieldBegin('headerNames', Thrift.Type.LIST, 1); output.writeListBegin(Thrift.Type.STRING, this.headerNames.length); - for (var iter226 in this.headerNames) { - if (this.headerNames.hasOwnProperty(iter226)) { - iter226 = this.headerNames[iter226]; - output.writeString(iter226); + for (var iter221 in this.headerNames) { + if (this.headerNames.hasOwnProperty(iter221)) { + iter221 = this.headerNames[iter221]; + output.writeString(iter221); } } output.writeListEnd(); @@ -11116,14 +10080,14 @@ TProgressUpdateResp.prototype.write = function(output) { if (this.rows !== null && this.rows !== undefined) { output.writeFieldBegin('rows', Thrift.Type.LIST, 2); output.writeListBegin(Thrift.Type.LIST, this.rows.length); - for (var iter227 in this.rows) { - if (this.rows.hasOwnProperty(iter227)) { - iter227 = this.rows[iter227]; - output.writeListBegin(Thrift.Type.STRING, iter227.length); - for (var iter228 in iter227) { - if (iter227.hasOwnProperty(iter228)) { - iter228 = iter227[iter228]; - output.writeString(iter228); + for (var iter222 in this.rows) { + if (this.rows.hasOwnProperty(iter222)) { + iter222 = this.rows[iter222]; + output.writeListBegin(Thrift.Type.STRING, iter222.length); + for (var iter223 in iter222) { + if (iter222.hasOwnProperty(iter223)) { + iter223 = iter222[iter223]; + output.writeString(iter223); } } output.writeListEnd();