Oracle operators require Oracle client for Linux. You will first need to get the OCI client from the official website, or use an existing one that is available. For development purposes:

• You can configure to have the client available on the k8s cluster using the vsystem app.

• As part of flowagent startup, it looks for /vrep/flowagent/tp-clients-env.sh

• If the file does not exist, please create the file with the following contents:

  export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/path/to/instantclient/
  export NLS_LANG=AMERICAN_AMERICA.UTF8 #For UTF-8 support

• Otherwise modify the file to contain the path to your client.

• Download OCI client from here.

• You can configure to have the client available on the k8s cluster using the vsystem app. Let's assume you upload and extract it to /vrep/flowagent/dbclients

• Now you can configure the OCI client using the commands below:

  cd $ORACLE_INSTANT_CLIENT/instantclient_12_2
    ln -s libclntsh.so.12.1 libclntsh.so.12  
    ln -s libclntsh.so.12 libclntsh.so
    ln -s libclntshcore.so.12.1 libclntshcore.so.12
    ln -s libclntshcore.so.12 libclntshcore.so
    ln -s libocci.so.12.1 libocci.so.12
    ln -s libocci.so.12 libocci.so

• As part of flowagent startup it looks for /vrep/flowagent/tp-clients-env.sh

• If the file does not exists, please create the file with the following contents:

  export ORACLE_INSTANT_CLIENT=/vrep/flowagent/dbclients
  export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:$ORACLE_INSTANT_CLIENT/instantclient_12_2
  export NLS_LANG=AMERICAN_AMERICA.UTF8 #For UTF-8 support

Logical Partitions are user defined partitions on how to read data from the source. For Table consumer, you can choose the partition type and then add the partition specification as below. For SQL consumer, we allow a user to type in any SQL that the underlying source supports. To allow partition logic to be used, a user would need to write the SQL with the $partition_specification. We will replace this object with partition information based on the provided specification.

• defaultPartition:

  The partition which will fetch all rows which were not filtered by the other partitions (you can disable it by setting defaultPartition to false)

• conditions:
  Each condition represents a set of filters which will be performed on a certain column:

  • columnExpression: The column where the filters will be applied. It can be either the column name or a function on it (i.e., TRUNC(EMPLOYEE_NAME))

  • type: The filter type. It can be either “LIST” (to filter exact values) or “RANGE” (to filter a range of values);

  • dataType: The data type of the elements. It can be either “STRING”, “NUMBER” or “EXPRESSION”;

  • elements: Each element represents a different filter, and its semantics depends on the “type” (see above).

• When more than one condition is presented, it will be performed a Cartesian product among the elements of each condition:

  • Condition A: [C1, C2]

  • Condition B: [C3, C4]

  • Resulting filters: [(C1, C3), (C1, C4), (C2, C3), (C2, C4)]

{
  "defaultPartition": true,
  "conditions": [
    {
      "columnExpression": "EMPLOYEE_ID",
      "type": "RANGE",
      "dataType": "NUMBER",
      "elements": [
        "10",
        "20",
        "30"
      ]
    }
  ]
}

String partitions:

{
  "defaultPartition": true,
  "conditions": [
    {
      "columnExpression": "EMPLOYEE_NAME",
      "type": "RANGE",
      "dataType": "STRING",
      "elements": [
        "M",
        "T"
      ]
    }
  ]
}

Expression partitions:

{
  "defaultPartition": true, 
  "conditions": [
    {
      "columnExpression": "EMPLOYEE_ADMISSION_DATE",
      "type": "RANGE",
      "dataType": "EXPRESSION",
      "elements": [
        "TO_DATE('2012-01-01', 'YYYY-MM-DD')",
        "TO_DATE('2015-01-01', 'YYYY-MM-DD')"
      ]
    }
  ]
}

{
  "defaultPartition": true, 
  "conditions": [
    {
      "columnExpression": "EMPLOYEE_ID",
      "type": "LIST",
      "dataType": "NUMBER",
      "elements": [
        "10",
        "20",
        "50"
      ]
    }
  ]
}

String partitions:

{
  "defaultPartition": false,
  "conditions": [
    {
      "columnExpression": "EMPLOYEE_NAME",
      "type": "LIST",
      "dataType": "STRING",
      "elements": [
        "Jhon",
        "Ana",
        "Beatrice"
      ]
    }
  ]
}

Expression partitions:

{
  "defaultPartition": false,
  "conditions": [
    {
      "columnExpression": "TRUNC(EMPLOYEE_ADMISSION_DATE)",
      "type": "LIST",
      "dataType": "EXPRESSION",
      "elements": [
        "TO_DATE('2012-07-17', 'YYYY-MM-DD')"
      ]
    }
  ]
}