org
.
apache
.
spark
.
h2o
.
backends
.
external
ExternalWriteConverterCtx
Related Docs:
object ExternalWriteConverterCtx
|
package external
class
ExternalWriteConverterCtx
extends
WriteConverterCtx
Linear Supertypes
WriteConverterCtx
,
AnyRef
,
Any
Ordering
Alphabetic
By Inheritance
Inherited
ExternalWriteConverterCtx
WriteConverterCtx
AnyRef
Any
Hide All
Show All
Visibility
Public
All
Instance Constructors
new
ExternalWriteConverterCtx
(
nodeDesc:
NodeDesc
,
writeTimeout:
Int
,
driverTimeStamp:
Short
,
blockSize:
Long
)
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
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
def
closeChunks
(
numRows:
Int
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
createChunk
(
keystr:
String
,
numRows:
Option
[
Int
]
,
expectedTypes:
Array
[
Byte
]
,
chunkId:
Int
,
maxVecSizes:
Array
[
Int
]
,
sparse:
Array
[
Boolean
]
,
vecStartSize:
Map
[
Int
,
Int
]
)
:
Unit
Initialize the communication before the chunks are created
Initialize the communication before the chunks are created
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
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]
)
def
finalizeFrame
(
key:
String
,
rowsPerChunk:
Array
[
Long
]
,
colTypes:
Array
[
Byte
]
,
domains:
Array
[
Array
[
String
]] =
null
)
:
H2OFrame
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
finishRow
()
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
def
initFrame
(
key:
String
,
columns:
Array
[
String
]
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
def
numOfRows
()
:
Int
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
String
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Date
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Timestamp
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Double
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Float
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Long
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Int
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Short
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Char
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Byte
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
put
(
colIdx:
Int
,
data:
Boolean
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
putAnySupportedType
[
T
]
(
colIdx:
Int
,
data:
T
)
:
Unit
Definition Classes
WriteConverterCtx
def
putDenseVector
(
startIdx:
Int
,
vector:
DenseVector
,
maxVecSize:
Int
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
putNA
(
columnNum:
Int
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
putSparseVector
(
startIdx:
Int
,
vector:
SparseVector
,
maxVecSize:
Int
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
def
putVector
(
startIdx:
Int
,
vec:
Vector
,
maxVecSize:
Int
)
:
Unit
Definition Classes
WriteConverterCtx
def
putVector
(
startIdx:
Int
,
vec:
Vector
,
maxVecSize:
Int
)
:
Unit
Definition Classes
WriteConverterCtx
def
startRow
(
rowIdx:
Int
)
:
Unit
Definition Classes
ExternalWriteConverterCtx
→
WriteConverterCtx
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
AnyRef → Any
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
WriteConverterCtx
Inherited from
AnyRef
Inherited from
Any
Ungrouped