AddElementsFromSocket

See javadoc - uk.gov.gchq.gaffer.operation.impl.add.AddElementsFromSocket

Available since Gaffer version 1.0.0

This is not a core operation. To enable it to be handled by Apache Flink, see flink-library/README.md

Required fields

The following fields are required:

  • hostname
  • port
  • elementGenerator

Examples

Add elements from socket

Java
JSON
Full JSON
Python
final AddElementsFromSocket op = new AddElementsFromSocket.Builder()
        .hostname("localhost")
        .port(8080)
        .delimiter(",")
        .generator(ElementGenerator.class)
        .parallelism(1)
        .validate(true)
        .skipInvalidElements(false)
        .build();
{
  "class" : "AddElementsFromSocket",
  "hostname" : "localhost",
  "port" : 8080,
  "elementGenerator" : "ElementGenerator",
  "delimiter" : ",",
  "parallelism" : 1,
  "skipInvalidElements" : false,
  "validate" : true
}
{
  "class" : "uk.gov.gchq.gaffer.operation.impl.add.AddElementsFromSocket",
  "hostname" : "localhost",
  "port" : 8080,
  "elementGenerator" : "uk.gov.gchq.gaffer.doc.operation.generator.ElementGenerator",
  "delimiter" : ",",
  "parallelism" : 1,
  "skipInvalidElements" : false,
  "validate" : true
}
g.AddElementsFromSocket( 
  hostname="localhost", 
  port=8080, 
  element_generator="uk.gov.gchq.gaffer.doc.operation.generator.ElementGenerator", 
  parallelism=1, 
  validate=True, 
  skip_invalid_elements=False, 
  delimiter="," 
)

results matching ""

    No results matching ""