Method main

serving/processor/tests/flatbuf_test/java/perf.java:517–632

(String[] args)

  }

  public static void main(String[] args) {

    String signatureName = "default_serving";
    String[] inputNames = new String[TOTAL_COUNT];
    int[] dataTypes = new int[TOTAL_COUNT];
    long[][] shapes = new long[TOTAL_COUNT][2];
    float[][] floatContent = new float[FLOAT_COUNT][DIM_0*DIM_1];
    long[][] longContent = new long[LONG_COUNT][DIM_0*DIM_1];
    double[][] doubleContent = new double[DOUBLE_COUNT][DIM_0*DIM_1];
    int[][] intContent = new int[INT_COUNT][DIM_0*DIM_1];
    String[][] stringContent = new String[STRING_COUNT][DIM_0*DIM_1];
    String[] fetchNames = new String[3];

    prepareData(signatureName, inputNames, dataTypes, shapes,
                floatContent, longContent, doubleContent,
                intContent, stringContent, fetchNames);

    if (PRINT_DATA) {
      printData(signatureName, inputNames, dataTypes, shapes,
                floatContent, longContent, doubleContent,
                intContent, stringContent, fetchNames);
    }

    // ================ flatbuffer ===================
    double startFBMillis = System.currentTimeMillis();
    int fbLen = 0;
    for (int x = 0; x < TESTING_COUNT; ++x) {
      // encode
      FlatBufferBuilder fbb = new FlatBufferBuilder(20000);

      // no copy here, convert user content to
      // flatbuffer data directly.
      encodeByFlatBuffer(fbb, signatureName, inputNames, dataTypes,
                         shapes, floatContent, longContent,
                         doubleContent, intContent,
                         stringContent, fetchNames);
  
      byte[] buf = fbb.sizedByteArray();
      fbLen = buf.length;

      if (WRITE_TO_FILE) {
        try {
          File file = new File("/tmp/request_buf.bin");
          FileOutputStream fop = new FileOutputStream(file);
          fop.write(buf);
          fop.flush();
          fop.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }

      if (PRINT_FB) {
        printFB(ByteBuffer.wrap(buf));
      }
    }
    double endFBMillis = System.currentTimeMillis();