23cca4e37b58e0ff1b8213529858eeae6a1e5d91
Files Diff
- Added: 7
- Removed: 1
- Renamed: 0
- Modified: 33
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 2 | ||
Change Parameter Type sourceContext : SourceContext<TBase> to sourceContext : SourceContext<ThriftRequest> in method public setStatHandlerTcpDispatchHandler(sourceContext SourceContext<ThriftRequest>) : void in class com.navercorp.pinpoint.flink.Bootstrap | From | To | |
Change Parameter Type ctx : SourceContext<TBase> to ctx : SourceContext<ThriftRequest> in method public run(ctx SourceContext<ThriftRequest>) : void in class com.navercorp.pinpoint.flink.receiver.TcpSourceFunction | From | To | |
Rename Variable | 1 | ||
Rename Variable tBase : TBase<?,?> to thriftRequest : ThriftRequest in method public handleSend(packet SendPacket, pinpointSocket PinpointSocket) : void in class com.navercorp.pinpoint.collector.receiver.tcp.DefaultTCPPacketHandler | From | To | |
Move Class | 1 | ||
Move Class flink.process.TBaseFlatMapperTest moved to com.navercorp.pinpoint.flink.process.TBaseFlatMapperTest | From | To | |
Extract Variable | 1 | ||
Extract Variable tBase : TBase<?,?> in method public throwExceptionTest1() : void from class com.navercorp.pinpoint.collector.receiver.DispatchHandlerTest | From | To | |
Change Variable Type | 2 | ||
Change Variable Type tBase : TBase<?,?> to thriftRequest : ThriftRequest in method public handleSend(packet SendPacket, pinpointSocket PinpointSocket) : void in class com.navercorp.pinpoint.collector.receiver.tcp.DefaultTCPPacketHandler | From | To | |
Change Variable Type rawData : DataStreamSource<TBase> to rawData : DataStreamSource<ThriftRequest> in method public start() : void in class com.navercorp.pinpoint.flink.StatStreamingVer2Job | From | To | |
Extract Method | 3 | ||
Extract Method public writeHeader(base TBase<?,?>) : void extracted from public continueSerialize(base TBase<?,?>) : byte[] in class com.navercorp.pinpoint.thrift.io.HeaderTBaseSerializer | From | To | |
Extract Method public writeHeader(base TBase<?,?>) : void extracted from public serialize(base TBase<?,?>) : byte[] in class com.navercorp.pinpoint.thrift.io.HeaderTBaseSerializer | From | To | |
Extract Method private createHeaderv1(type short) : Header extracted from private createHeader(type short) : Header in class com.navercorp.pinpoint.thrift.io.FlinkTBaseLocator | From | To |