This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8"?> | |
<!--Created:ce44715c-8c4e-446b-879c-ea9ebe0f09c8--> | |
<OfficeApp | |
xmlns="http://schemas.microsoft.com/office/appforoffice/1.1" | |
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | |
xmlns:bt="http://schemas.microsoft.com/office/officeappbasictypes/1.0" | |
xmlns:mailappor="http://schemas.microsoft.com/office/mailappversionoverrides/1.0" | |
xsi:type="MailApp"> | |
<!-- Begin Basic Settings: Add-in metadata, used for all versions of Office unless override provided. --> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
curl --request POST \ | |
--url http://localhost:8090/druid/indexer/v1/supervisor \ | |
--header 'content-type: application/json' \ | |
--data '{ | |
"type": "kafka", | |
"dataSchema": { | |
"dataSource": "meetup-kafka", | |
"parser": { | |
"type": "string", | |
"parseSpec": { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/* Software License Agreement (BSD License) | |
* | |
* Copyright (c) 2010-2011, Rustici Software, LLC | |
* All rights reserved. | |
* | |
* Redistribution and use in source and binary forms, with or without | |
* modification, are permitted provided that the following conditions are met: | |
* * Redistributions of source code must retain the above copyright | |
* notice, this list of conditions and the following disclaimer. | |
* * Redistributions in binary form must reproduce the above copyright |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import cats.effect.{ExitCode, IO, IOApp, Resource} | |
import cats.implicits._ | |
import config.DataBaseConfig | |
import doobie.hikari.HikariTransactor | |
import doobie.implicits._ | |
import doobie.util.ExecutionContexts | |
object Test extends IOApp { | |
val dbConfig = DataBaseConfig() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
using System; | |
using System.Collections.Generic; | |
using System.IO; | |
using System.Xml; | |
using System.Xml.Linq; | |
using Microsoft.Exchange.WebServices.Data; | |
using System.Linq; | |
using System.Net; | |
using System.Security; | |
using System.Text; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<!DOCTYPE html> | |
<html lang="en"> | |
<head> | |
<title>File downloader</title> | |
</head> | |
<body> | |
<div id="progress-msg">File is downloading. Please wait...</div> | |
<script> | |
function saveAs(blob, fileName) { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8"?> | |
<!--Created:ce44715c-8c4e-446b-879c-ea9ebe0f09c8--> | |
<OfficeApp | |
xmlns="http://schemas.microsoft.com/office/appforoffice/1.1" | |
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | |
xmlns:bt="http://schemas.microsoft.com/office/officeappbasictypes/1.0" | |
xmlns:mailappor="http://schemas.microsoft.com/office/mailappversionoverrides/1.0" | |
xsi:type="MailApp"> | |
<!-- Begin Basic Settings: Add-in metadata, used for all versions of Office unless override provided. --> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* Hacky Workaround for Getting the Current Context Classloader | |
* Executing Some arbitrary Sync with the Hbase Classloader | |
* Then reseting that thread to how it was previously. | |
* | |
* The moments I believe this is neccessary is when connections or | |
* configurations are being created to HBase. At these times it | |
* needs to have the hbase-default.xml which it will be lacking | |
* otherwise. | |
* |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
//Lmabda function1 | |
//API1 : takes feature names as user input and returns all sub processses running status in response. | |
def lambda_handler(event, context): | |
config = load config from env variable. | |
take service names from user input(event) | |
extract corresponding micro services names mapped to feature name. | |
now we hit all machines where these micro services are running aggregate the status and return. | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import cats.MonadError | |
import cats.instances.either._ | |
import cats.instances.future._ | |
import cats.instances.try_._ | |
import cats.syntax.applicativeError._ | |
import cats.syntax.flatMap._ | |
import scala.concurrent.ExecutionContext.Implicits.global | |
import scala.concurrent.duration._ | |
import scala.concurrent.{Await, Future} |
NewerOlder