public class QueryResultFetchingSession extends ResultFetchingSession
Constructor and Description |
---|
QueryResultFetchingSession(String jobId,
IDliServiceProxy serviceProxy,
int bufferSize) |
QueryResultFetchingSession(String jobId,
IDliServiceProxy serviceProxy,
int bufferSize,
com.huawei.dli.sdk.common.TableSchema schemaOrigin) |
QueryResultFetchingSession(String jobId,
IDliServiceProxy serviceProxy,
com.huawei.dli.sdk.common.TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
getFetchedRows() |
DliResultSetMetaData |
getSchema() |
long |
getTotalCount() |
Object[] |
readNextRecord() |
resolveSchema
public QueryResultFetchingSession(String jobId, IDliServiceProxy serviceProxy, int bufferSize) throws DliException
DliException
public QueryResultFetchingSession(String jobId, IDliServiceProxy serviceProxy, int bufferSize, com.huawei.dli.sdk.common.TableSchema schemaOrigin) throws DliException
DliException
public QueryResultFetchingSession(String jobId, IDliServiceProxy serviceProxy, com.huawei.dli.sdk.common.TableSchema schema) throws DliException
DliException
public Object[] readNextRecord() throws DliException
readNextRecord
in class ResultFetchingSession
DliException
public long getTotalCount()
getTotalCount
in class ResultFetchingSession
public int getFetchedRows()
getFetchedRows
in class ResultFetchingSession
public DliResultSetMetaData getSchema()
getSchema
in class ResultFetchingSession
public void close()
close
in class ResultFetchingSession
Copyright © 2023. All rights reserved.