sebge2emasphere

JavaPairRDD
                .fromRDD(
                        context.newAPIHadoopRDD(
                                initializeConfiguration(executorContext, context),
                                TableInputFormat.class,
                                ImmutableBytesWritable.class,
                                Result.class
                        ),
                        ClassTag$.MODULE$.apply(ImmutableBytesWritable.class),
                        ClassTag$.MODULE$.apply(Result.class)

sebge2emasphere

2017-10-18 07:30:47 INFO  CoarseGrainedExecutorBackend:54 - Got assigned task 20
2017-10-18 07:30:47 INFO  CoarseGrainedExecutorBackend:54 - Got assigned task 21
2017-10-18 07:30:47 INFO  Executor:54 - Running task 0.0 in stage 18.0 (TID 20)
2017-10-18 07:30:47 DEBUG Executor:58 - Task 20's epoch is 10
2017-10-18 07:30:47 DEBUG BlockManager:58 - Getting local block broadcast_18
2017-10-18 07:30:47 DEBUG BlockManager:58 - Block broadcast_18 was not found
2017-10-18 07:30:47 INFO  TorrentBroadcast:54 - Started reading broadcast variable 18
2017-10-18 07:30:47 DEBUG TorrentBroadcast:58 - Reading piece broadcast_18_piece0 of broadcast_18
2017-10-18 07:30:47 DEBUG BlockManager:58 - Getting local block broadcast_18_piece0 as bytes
2017-10-18 07:30:47 DEBUG BlockManager:58 - Getting remote block broadcast_18_piece0

sebge2emasphere

2017-10-26 14:35:57 TRACE MessageDecoder:47 - Received message OneWayMessage: OneWayMessage{body=NettyManagedBuffer{buf=CompositeByteBuf(ridx: 5, widx: 8470, cap: 8470, components=9)}}
2017-10-26 14:35:57 INFO  CoarseGrainedExecutorBackend:54 - Got assigned task 62
2017-10-26 14:35:57 INFO  Executor:54 - Running task 0.0 in stage 72.0 (TID 62)
2017-10-26 14:35:57 DEBUG Executor:58 - Task 62's epoch is 40
2017-10-26 14:35:57 DEBUG BlockManager:58 - Getting local block broadcast_65
2017-10-26 14:35:57 TRACE BlockInfoManager:62 - Task 62 trying to acquire read lock for broadcast_65
2017-10-26 14:35:57 DEBUG BlockManager:58 - Block broadcast_65 was not found
2017-10-26 14:35:57 INFO  TorrentBroadcast:54 - Started reading broadcast variable 65
2017-10-26 14:35:57 DEBUG TorrentBroadcast:58 - Reading piece broadcast_65_piece0 of broadcast_65
2017-10-26 14:35:57 DEBUG BlockManager:58 - Getting local block broadcast_65_piece0 as bytes

sebge2emasphere

2017-10-26 15:30:22 TRACE AbstractRpcClient:236 - Call: Scan, callTime: 5ms
2017-10-26 15:30:22 TRACE ScannerCallableWithReplicas:234 - Setting current scanner as id=-1 associated with replica=0
2017-10-26 15:30:22 TRACE MetaCache:175 - Merged cached locations: [region=flow,,1508569108231.4e4d11e77742818f3c7ee4782f787b16., hostname=ip-172-31-15-200.ec2.internal,16020,1509031400543, seqNum=2772]
2017-10-26 15:30:22 TRACE AbstractRpcClient:236 - Call: Scan, callTime: 1ms
2017-10-26 15:30:22 TRACE ScannerCallableWithReplicas:234 - Setting current scanner as id=23 associated with replica=0
2017-10-26 15:30:22 TRACE AbstractRpcClient:236 - Call: Scan, callTime: 501ms
2017-10-26 15:30:22 TRACE ScannerCallableWithReplicas:234 - Setting current scanner as id=23 associated with replica=0
2017-10-26 15:30:22 TRACE ClientScanner:651 - number results from RPC: 20000,partial != null: false,number of partials so far: 0
2017-10-26 15:30:23 TRACE AbstractRpcClient:236 - Call: Scan, callTime: 582ms
2017-10-26 15:30:23 TRACE S

sebge2emasphere

2017-10-30 15:09:40,443 DEBUG [RpcServer.listener,port=16020] ipc.RpcServer: RpcServer.listener,port=16020: connection from 172.31.15.200:56894; # active connections: 3
2017-10-30 15:09:40,470 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.DFSClient: Connecting to datanode 172.31.15.200:50010
2017-10-30 15:09:40,470 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: BlockReaderFactory(fileName=/user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7, block=BP-983401122-172.31.15.200-1508568126354:blk_1073746500_5714): trying to create a remote block reader from a TCP socket
2017-10-30 15:09:40,471 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: nextTcpPeer: reusing existing peer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51498])
2017-10-30 15:09:40,471 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.DataTransferProtocol: Sending Data

sebge2emasphere

{
  "id": "718136c7-56c9-48be-ab15-7175bcab846d",
  "reference": "analysecom",
  "internalReference": "analysecom",
  "label": "Analyse Commerciale",
  "displayedText": "Analyse Commerciale",
  "description": "",
  "status": "EDITING",
  "entryDefinition": {
    "key": {

sebge2emasphere

[
  {
    "time": "2018-01-26T14:20:38.079Z",
    "entryIndex": 0,
    "level": "INFO",
    "message": "test",
    "details": {
      "validationResult": {
        "successful": false,
        "messages": [

sebge2emasphere

#!/bin/bash

key="xyz"
cookieFile="/tmp/cookie-refresh.txt"
baseUrl="https://nexis.ema.emasphere.com"

declare -A situations
situations=([ba14ee31-b3a5-4d9f-88a7-62cbdb357b91]="2018-03" [9bb1659f-061d-453f-be37-6f33b62d8558]="2018-03" [bd6268bf-ce50-4acd-8350-396c76c0c21c]="2018-02")

sebge2emasphere

package com.emasphere.operation.query.model.definition.matrix.dimension;

import com.emasphere.operation.injection.model.CodeLabel;
import com.emasphere.operation.query.model.SimpleRegexUtils;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonPOJOBuilder;

sebge2emasphere

{
  "id": "ec5d5ad9-8bbc-4e8f-a8aa-0a4582a32af2",
  "originalRenderingRequest": {
    "id": "4f59f37e-1cb8-44b8-81a0-f5b78f2135c4",
    "forceSynchronous": false,
    "type": "SIMPLE"
  },
  "clientExecutionContext": {
    "tenant": "29e78c6e-aca7-4211-9f95-31cc8c3fd327",
    "currentDay": "2018-04-30",