Preparing search index...
The search index is not available
apache-beam
apache-beam
utils/service
PythonService
Class PythonService
Hierarchy
SubprocessService
PythonService
Index
Constructors
constructor
Properties
address?
args
cached
cmd
name
process
VENV_
CACHE
cache?
Methods
key
port
Ready
start
stop
beam
Python
create
Cache
for
Module
free
Port
which
Python
Constructors
Private
constructor
new
Python
Service
(
pythonExecutablePath
:
string
, module
:
string
, args
?:
string
[]
)
:
PythonService
Parameters
pythonExecutablePath:
string
module:
string
args:
string
[]
= []
Returns
PythonService
Properties
Optional
address
address
?:
string
args
args
:
string
[]
cached
cached
:
boolean
cmd
cmd
:
string
name
name
:
string
process
process
:
ChildProcess
Static
VENV_
CACHE
VENV_
CACHE
:
any
= ...
Static
Optional
cache
cache
?:
SubprocessServiceCache
= undefined
Methods
key
key
(
)
:
string
Returns
string
port
Ready
port
Ready
(
port
:
any
, host
:
any
, timeoutMs
:
any
, iterMs
?:
number
)
:
Promise
<
void
>
Parameters
port:
any
host:
any
timeoutMs:
any
iterMs:
number
= 100
Returns
Promise
<
void
>
start
start
(
)
:
Promise
<
string
>
Returns
Promise
<
string
>
stop
stop
(
)
:
Promise
<
void
>
Returns
Promise
<
void
>
Static
beam
Python
beam
Python
(
)
:
string
Returns
string
Static
create
Cache
create
Cache
(
)
:
SubprocessServiceCache
Returns
SubprocessServiceCache
Static
for
Module
for
Module
(
module
:
string
, args
?:
string
[]
)
:
Service
Parameters
module:
string
args:
string
[]
= []
Returns
Service
Static
free
Port
free
Port
(
)
:
Promise
<
number
>
Returns
Promise
<
number
>
Static
which
Python
which
Python
(
)
:
string
Returns
string
Settings
Member Visibility
Protected
Private
Inherited
External
Theme
OS
Light
Dark
Modules
apache-
beam
coders/coders
coders/js_
coders
coders/required_
coders
coders/row_
coder
coders/standard_
coders
index
io
io
io/avroio
io/avroio
io/bigqueryio
io/bigqueryio
io/kafka
io/kafka
io/parquetio
io/parquetio
io/pubsub
io/pubsub
io/pubsublite
io/pubsublite
io/schemaio
io/schemaio
io/textio
io/textio
options/pipeline_
options
pvalue
runners
runners
runners/dataflow
runners/dataflow
runners/direct_
runner
runners/direct_
runner
runners/flink
runners/flink
runners/portable_
runner/runner
runners/portable_
runner/runner
runners/runner
runners/runner
runners/universal
runners/universal
serialization
testing/assert
testing/assert
testing/multi_
pipeline_
runner
testing/multi_
pipeline_
runner
testing/proto_
printing_
runner
testing/proto_
printing_
runner
transforms
transforms
transforms/combiners
transforms/combiners
transforms/create
transforms/create
transforms/external
transforms/external
transforms/flatten
flatten
transforms/flatten
transforms/group_
and_
combine
transforms/group_
and_
combine
transforms/internal
combine
Per
Key
group
By
Key
impulse
transforms/internal
transforms/pardo
par
Do
transforms/pardo
transforms/python
transforms/python
transforms/sql
transforms/sql
transforms/transform
transforms/transform
transforms/utils
transforms/utils
transforms/window
transforms/window
transforms/windowings
transforms/windowings
utils/package
Json
utils/service
values
Python
Service
constructor
address?
args
cached
cmd
name
process
VENV_
CACHE
cache?
key
port
Ready
start
stop
beam
Python
create
Cache
for
Module
free
Port
which
Python
Generated using
TypeDoc