org
.
apache
.
hive
.
service
.
cli
.
operation
OperationManager
Related Doc:
package operation
class
OperationManager
extends
AbstractService
Linear Supertypes
AbstractService
,
Service
,
AnyRef
,
Any
Ordering
Alphabetic
By Inheritance
Inherited
OperationManager
AbstractService
Service
AnyRef
Any
Hide All
Show All
Visibility
Public
All
Instance Constructors
new
OperationManager
()
Type Members
type
STATE
=
Service.STATE
Attributes
protected
Definition Classes
Service
Value Members
final
def
!=
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
final
def
##
()
:
Int
Definition Classes
AnyRef → Any
final
def
==
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
final
def
asInstanceOf
[
T0
]
:
T0
Definition Classes
Any
def
cancelOperation
(
opHandle:
OperationHandle
)
:
Unit
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
def
closeOperation
(
opHandle:
OperationHandle
)
:
Unit
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
classOf[java.lang.Throwable]
)
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
def
getHiveConf
()
:
HiveConf
Definition Classes
AbstractService
→
Service
def
getName
()
:
String
Definition Classes
AbstractService
→
Service
def
getOperation
(
operationHandle:
OperationHandle
)
:
Operation
def
getOperationLogByThread
()
:
OperationLog
def
getOperationLogRowSet
(
opHandle:
OperationHandle
,
orientation:
FetchOrientation
,
maxRows:
Long
)
:
RowSet
def
getOperationNextRowSet
(
opHandle:
OperationHandle
,
orientation:
FetchOrientation
,
maxRows:
Long
)
:
RowSet
def
getOperationNextRowSet
(
opHandle:
OperationHandle
)
:
RowSet
def
getOperationResultSetSchema
(
opHandle:
OperationHandle
)
:
TableSchema
def
getOperationStatus
(
opHandle:
OperationHandle
)
:
OperationStatus
def
getServiceState
()
:
STATE
Definition Classes
AbstractService
→
Service
def
getStartTime
()
:
Long
Definition Classes
AbstractService
→
Service
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
def
init
(
hiveConf:
HiveConf
)
:
Unit
Definition Classes
OperationManager
→
AbstractService
→
Service
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
newExecuteStatementOperation
(
parentSession:
HiveSession
,
statement:
String
,
confOverlay:
Map
[
String
,
String
]
,
runAsync:
Boolean
)
:
ExecuteStatementOperation
def
newGetCatalogsOperation
(
parentSession:
HiveSession
)
:
GetCatalogsOperation
def
newGetColumnsOperation
(
parentSession:
HiveSession
,
catalogName:
String
,
schemaName:
String
,
tableName:
String
,
columnName:
String
)
:
GetColumnsOperation
def
newGetFunctionsOperation
(
parentSession:
HiveSession
,
catalogName:
String
,
schemaName:
String
,
functionName:
String
)
:
GetFunctionsOperation
def
newGetSchemasOperation
(
parentSession:
HiveSession
,
catalogName:
String
,
schemaName:
String
)
:
GetSchemasOperation
def
newGetTableTypesOperation
(
parentSession:
HiveSession
)
:
GetTableTypesOperation
def
newGetTablesOperation
(
parentSession:
HiveSession
,
catalogName:
String
,
schemaName:
String
,
tableName:
String
,
tableTypes:
List
[
String
]
)
:
MetadataOperation
def
newGetTypeInfoOperation
(
parentSession:
HiveSession
)
:
GetTypeInfoOperation
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
def
register
(
l:
ServiceStateChangeListener
)
:
Unit
Definition Classes
AbstractService
→
Service
def
removeExpiredOperations
(
handles:
Array
[
OperationHandle
]
)
:
List
[
Operation
]
def
start
()
:
Unit
Definition Classes
OperationManager
→
AbstractService
→
Service
def
stop
()
:
Unit
Definition Classes
OperationManager
→
AbstractService
→
Service
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
AnyRef → Any
def
unregister
(
l:
ServiceStateChangeListener
)
:
Unit
Definition Classes
AbstractService
→
Service
final
def
wait
()
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
,
arg1:
Int
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
Inherited from
AbstractService
Inherited from
Service
Inherited from
AnyRef
Inherited from
Any
Ungrouped