Examples of writeStructEnd()

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

95
96
97
98
99
100
101
102
            break;
        case 3:
            writer.writeEnumField("fruitValue", (short) 3, fruitCodec, value.fruitValue);
            break;
        }
        writer.writeStructEnd();
    }
}
View Full Code Here

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

282
283
284
285
286
287
288
289
290
291
292
        out.writeMessageBegin(new TMessage(name, responseType, sequenceId));

        TProtocolWriter writer = new TProtocolWriter(out);
        writer.writeStructBegin(resultStructName);
        writer.writeField(responseFieldName, (short) responseFieldId, responseCodec, result);
        writer.writeStructEnd();

        out.writeMessageEnd();
        out.getTransport().flush();
    }
View Full Code Here

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

289
290
291
292
293
294
295
296
297
298
299
        for (int i = 0; i < args.length; i++) {
            Object value = args[i];
            ParameterHandler parameter = parameterCodecs.get(i);
            writer.writeField(parameter.getName(), parameter.getId(), parameter.getCodec(), value);
        }
        writer.writeStructEnd();

        out.writeMessageEnd();
        out.getTransport().flush();
    }
View Full Code Here

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

123
124
125
126
127
128
129
130
        writer.writeI64Field("aLong", (short) 5, oneOfEverything.aLong);
        writer.writeDoubleField("aDouble", (short) 6, oneOfEverything.aDouble);
        writer.writeStringField("aString", (short) 7, oneOfEverything.aString);
        writer.writeStructField("aStruct", (short) 8, aStructCodec, oneOfEverything.aStruct);
        writer.writeSetField("aBooleanSet", (short) 9, aBooleanSetCodec, oneOfEverything.aBooleanSet);
        writer.writeStructEnd();
    }
}
View Full Code Here

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

315
316
317
318
319
320
321
322
323
324
325
        out.writeMessageBegin(new TMessage(name, responseType, sequenceId));

        TProtocolWriter writer = new TProtocolWriter(out);
        writer.writeStructBegin(resultStructName);
        writer.writeField(responseFieldName, (short) responseFieldId, responseCodec, result);
        writer.writeStructEnd();

        out.writeMessageEnd();
        out.getTransport().flush();
    }
View Full Code Here

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

304
305
306
307
308
309
310
311
312
313
314
        for (int i = 0; i < args.length; i++) {
            Object value = args[i];
            ParameterHandler parameter = parameterCodecs.get(i);
            writer.writeField(parameter.getName(), parameter.getId(), parameter.getCodec(), value);
        }
        writer.writeStructEnd();

        out.writeMessageEnd();
        out.getTransport().flush();
    }
View Full Code Here

Examples of com.facebook.swift.codec.internal.TProtocolWriter.writeStructEnd()

123
124
125
126
127
128
129
130
131
132
133
            if (fieldValue != null) {
                ThriftCodec<Object> codec = (ThriftCodec<Object>) fields.get(fieldMetadata.getId());
                writer.writeField(fieldMetadata.getName(), fieldMetadata.getId(), codec, fieldValue);
            }
        }
        writer.writeStructEnd();
    }

    private T constructStruct(Map<Short, Object> data)
            throws Exception
    {
View Full Code Here

Examples of com.facebook.thrift.protocol.TProtocol.writeStructEnd()

422
423
424
425
426
427
428
429
430
431
432
    TField field = new TField("test_field", testCase.type_, testCase.id_);
    proto.writeStructBegin(new TStruct("test_struct"));
    proto.writeFieldBegin(field);
    testCase.writeMethod(proto);
    proto.writeFieldEnd();
    proto.writeStructEnd();

    // System.out.println(buf.inspect());

    proto.readStructBegin();
    TField readField = proto.readFieldBegin();
View Full Code Here

Examples of org.apache.hadoop.hive.serde2.thrift.TCTLSeparatedProtocol.writeStructEnd()

155
156
157
158
159
160
161
162
163
164
165
   
    prot.writeFieldBegin(new TField());
    prot.writeString("bye!");
    prot.writeFieldEnd();

    prot.writeStructEnd();
    trans.flush();
    byte b[] = new byte[3*1024];
    int len = trans.read(b,0,b.length);
    String test = new String(b, 0, len);

View Full Code Here

Examples of org.apache.hadoop.hive.serde2.thrift.TCTLSeparatedProtocol.writeStructEnd()

257
258
259
260
261
262
263
264
265
266
267
    prot.writeString("elem1");
    prot.writeString("elem2");
    prot.writeListEnd();
    prot.writeFieldEnd();

    prot.writeStructEnd();
    prot.writeString("\n");

    trans.flush();

    byte b[] = new byte[4096];
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.