Package | Description |
---|---|
org.ballerinalang.nativeimpl.io.events.records | |
org.ballerinalang.nativeimpl.io.utils |
Constructor and Description |
---|
CloseDelimitedRecordEvent(DelimitedRecordChannel channel,
EventContext context) |
DelimitedRecordReadAllEvent(DelimitedRecordChannel channel,
EventContext context) |
DelimitedRecordReadEvent(DelimitedRecordChannel channel) |
DelimitedRecordReadEvent(DelimitedRecordChannel channel,
EventContext context) |
DelimitedRecordWriteEvent(DelimitedRecordChannel channel,
BStringArray content) |
DelimitedRecordWriteEvent(DelimitedRecordChannel channel,
BStringArray content,
EventContext context) |
HasNextDelimitedRecordEvent(DelimitedRecordChannel channel,
EventContext context) |
Modifier and Type | Method and Description |
---|---|
static DelimitedRecordChannel |
IOUtils.createDelimitedRecordChannel(String filePath,
String encoding,
String mode,
Format format)
Creates a delimited record channel to read from CSV file.
|
static DelimitedRecordChannel |
IOUtils.createDelimitedRecordChannel(String filePath,
String encoding,
String rs,
String fs)
Creates a delimited record channel to read from CSV file.
|
Modifier and Type | Method and Description |
---|---|
static void |
IOUtils.close(DelimitedRecordChannel charChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the delimited record channel asynchronously.
|
static void |
IOUtils.read(DelimitedRecordChannel recordChannel,
EventContext context,
Function<EventResult,EventResult> function)
Reads delimited records asynchronously.
|
static void |
IOUtils.write(DelimitedRecordChannel recordChannel,
BStringArray records,
EventContext context,
Function<EventResult,EventResult> function)
Asynchronously writes delimited records to the channel.
|
Copyright © 2018 WSO2. All rights reserved.